threadpoolexecutor.html
来自「j2se5-api-zh,java文档的中文版本」· HTML 代码 · 共 1,102 行 · 第 1/5 页
HTML
1,102 行
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd"><!--NewPage--><HTML><HEAD><!-- Generated by javadoc (build 1.5.0_03) on Wed Nov 02 09:51:51 CST 2005 --><META http-equiv="Content-Type" content="text/html; charset=gb2312"><TITLE>ThreadPoolExecutor (Java 2 Platform SE 5.0)</TITLE><META NAME="keywords" CONTENT="java.util.concurrent.ThreadPoolExecutor class"><LINK REL ="stylesheet" TYPE="text/css" HREF="../../../stylesheet.css" TITLE="Style"><SCRIPT type="text/javascript">function windowTitle(){ parent.document.title="ThreadPoolExecutor (Java 2 Platform SE 5.0)";}</SCRIPT><NOSCRIPT></NOSCRIPT></HEAD><BODY BGCOLOR="white" onload="windowTitle();"><!-- ========= START OF TOP NAVBAR ======= --><A NAME="navbar_top"><!-- --></A><A HREF="#skip-navbar_top" title="跳过导航链接"></A><TABLE BORDER="0" WIDTH="100%" CELLPADDING="1" CELLSPACING="0" SUMMARY=""><TR><TD COLSPAN=2 BGCOLOR="#EEEEFF" CLASS="NavBarCell1"><A NAME="navbar_top_firstrow"><!-- --></A><TABLE BORDER="0" CELLPADDING="0" CELLSPACING="3" SUMMARY=""> <TR ALIGN="center" VALIGN="top"> <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../overview-summary.html"><FONT CLASS="NavBarFont1"><B>概述</B></FONT></A> </TD> <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="package-summary.html"><FONT CLASS="NavBarFont1"><B>软件包</B></FONT></A> </TD> <TD BGCOLOR="#FFFFFF" CLASS="NavBarCell1Rev"> <FONT CLASS="NavBarFont1Rev"><B>类</B></FONT> </TD> <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="class-use/ThreadPoolExecutor.html"><FONT CLASS="NavBarFont1"><B>使用</B></FONT></A> </TD> <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="package-tree.html"><FONT CLASS="NavBarFont1"><B>树</B></FONT></A> </TD> <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../deprecated-list.html"><FONT CLASS="NavBarFont1"><B>已过时</B></FONT></A> </TD> <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../index-files/index-1.html"><FONT CLASS="NavBarFont1"><B>索引</B></FONT></A> </TD> <TD BGCOLOR="#EEEEFF" CLASS="NavBarCell1"> <A HREF="../../../help-doc.html"><FONT CLASS="NavBarFont1"><B>帮助</B></FONT></A> </TD> </TR></TABLE></TD><TD ALIGN="right" VALIGN="top" ROWSPAN=3><EM><b>Java<sup><font size=-2>TM</font></sup> 2 Platform<br>Standard Ed. 5.0</b></EM></TD></TR><TR><TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2"> <A HREF="ThreadFactory.html" title="java.util.concurrent 中的接口"><B>上一个类</B></A> <A HREF="ThreadPoolExecutor.AbortPolicy.html" title="java.util.concurrent 中的类"><B>下一个类</B></A></FONT></TD><TD BGCOLOR="white" CLASS="NavBarCell2"><FONT SIZE="-2"> <A HREF="../../../index.html@java_2Futil_2Fconcurrent_2FThreadPoolExecutor.html" target="_top"><B>框架</B></A> <A HREF="ThreadPoolExecutor.html" target="_top"><B>无框架</B></A> <SCRIPT type="text/javascript"> <!-- if(window==top) { document.writeln('<A HREF="../../../allclasses-noframe.html"><B>所有类</B></A>'); } //--></SCRIPT><NOSCRIPT> <A HREF="../../../allclasses-noframe.html"><B>所有类</B></A></NOSCRIPT></FONT></TD></TR><TR><TD VALIGN="top" CLASS="NavBarCell3"><FONT SIZE="-2"> 摘要： <A HREF="#nested_class_summary">嵌套</A> | 字段 | <A HREF="#constructor_summary">构造方法</A> | <A HREF="#method_summary">方法</A></FONT></TD><TD VALIGN="top" CLASS="NavBarCell3"><FONT SIZE="-2">详细信息： 字段 | <A HREF="#constructor_detail">构造方法</A> | <A HREF="#method_detail">方法</A></FONT></TD></TR></TABLE><A NAME="skip-navbar_top"></A><!-- ========= END OF TOP NAVBAR ========= --><HR><!-- ======== START OF CLASS DATA ======== --><H2><FONT SIZE="-1">java.util.concurrent</FONT><BR>类 ThreadPoolExecutor</H2><PRE><A HREF="../../lang/Object.html" title="java.lang 中的类">java.lang.Object</A> <IMG SRC="../../../resources/inherit.gif" ALT="继承者 "><A HREF="AbstractExecutorService.html" title="java.util.concurrent 中的类">java.util.concurrent.AbstractExecutorService</A> <IMG SRC="../../../resources/inherit.gif" ALT="继承者 "><B>java.util.concurrent.ThreadPoolExecutor</B></PRE><DL><DT><B>所有已实现的接口：</B> <DD><A HREF="Executor.html" title="java.util.concurrent 中的接口">Executor</A>, <A HREF="ExecutorService.html" title="java.util.concurrent 中的接口">ExecutorService</A></DD></DL><DL><DT><B>直接已知子类：</B> <DD><A HREF="ScheduledThreadPoolExecutor.html" title="java.util.concurrent 中的类">ScheduledThreadPoolExecutor</A></DD></DL><HR><DL><DT><PRE>public class <B>ThreadPoolExecutor</B><DT>extends <A HREF="AbstractExecutorService.html" title="java.util.concurrent 中的类">AbstractExecutorService</A></DL></PRE><P>一个 <A HREF="ExecutorService.html" title="java.util.concurrent 中的接口"><CODE>ExecutorService</CODE></A>，它使用可能的几个池线程之一执行每个提交的任务，通常使用 <A HREF="Executors.html" title="java.util.concurrent 中的类"><CODE>Executors</CODE></A> 工厂方法配置。<p>线程池可以解决两个不同问题：由于减少了每个任务调用的开销，它们通常可以在执行大量异步任务时提供增强的性能，并且还可以提供绑定和管理资源（包括执行集合任务时使用的线程）的方法。每个 <tt>ThreadPoolExecutor</tt> 还维护着一些基本的统计数据，如完成的任务数。<p>为了便于跨大量上下文使用，此类提供了很多可调整的参数和扩展挂钩。但是，强烈建议程序员使用较为方便的 <A HREF="Executors.html" title="java.util.concurrent 中的类"><CODE>Executors</CODE></A> 工厂方法 <A HREF="Executors.html#newCachedThreadPool()"><CODE>Executors.newCachedThreadPool()</CODE></A>（无界线程池，可以进行自动线程回收）、<A HREF="Executors.html#newFixedThreadPool(int)"><CODE>Executors.newFixedThreadPool(int)</CODE></A>（固定大小线程池）和 <A HREF="Executors.html#newSingleThreadExecutor()"><CODE>Executors.newSingleThreadExecutor()</CODE></A>（单个后台线程），它们均为大多数使用场景预定义了设置。否则，在手动配置和调整此类时，使用以下指导：<dl><dt>核心和最大池大小</dt><dd><tt>ThreadPoolExecutor</tt> 将根据 corePoolSize（参见 <A HREF="ThreadPoolExecutor.html#getCorePoolSize()"><CODE>getCorePoolSize()</CODE></A>）和 maximumPoolSize（参见 <A HREF="ThreadPoolExecutor.html#getMaximumPoolSize()"><CODE>getMaximumPoolSize()</CODE></A>）设置的边界自动调整池大小。当新任务在方法 <A HREF="ThreadPoolExecutor.html#execute(java.lang.Runnable)"><CODE>execute(java.lang.Runnable)</CODE></A> 中提交时，如果运行的线程少于 corePoolSize，则创建新线程来处理请求，即使其他辅助线程是空闲的。如果运行的线程多于 corePoolSize 而少于 maximumPoolSize，则仅当队列满时才创建新线程。如果设置的 corePoolSize 和 maximumPoolSize 相同，则创建了固定大小的线程池。如果将 maximumPoolSize 设置为基本的无界值（如 <tt>Integer.MAX_VALUE</tt>），则允许池适应任意数量的并发任务。在大多数情况下，核心和最大池大小仅基于构造来设置，不过也可以使用 <A HREF="ThreadPoolExecutor.html#setCorePoolSize(int)"><CODE>setCorePoolSize(int)</CODE></A> 和 <A HREF="ThreadPoolExecutor.html#setMaximumPoolSize(int)"><CODE>setMaximumPoolSize(int)</CODE></A> 进行动态更改。 <dd><dt> 按需构造<dd> 默认情况下，即使核心线程最初只是在新任务需要时才创建和启动的，也可以使用方法 <A HREF="ThreadPoolExecutor.html#prestartCoreThread()"><CODE>prestartCoreThread()</CODE></A> 或 <A HREF="ThreadPoolExecutor.html#prestartAllCoreThreads()"><CODE>prestartAllCoreThreads()</CODE></A> 对其进行动态重写。 </dd><dt>创建新线程</dt><dd>使用 <A HREF="ThreadFactory.html" title="java.util.concurrent 中的接口"><CODE>ThreadFactory</CODE></A> 创建新线程。如果没有另外说明，则在同一个 <A HREF="../../lang/ThreadGroup.html" title="java.lang 中的类"><CODE>ThreadGroup</CODE></A> 中一律使用 <A HREF="Executors.html#defaultThreadFactory()"><CODE>Executors.defaultThreadFactory()</CODE></A> 创建线程，并且这些线程具有相同的 <tt>NORM_PRIORITY</tt> 优先级和非守护进程状态。通过提供不同的 ThreadFactory，可以改变线程的名称、线程组、优先级、守护进程状态，等等。如果从 <tt>newThread</tt> 返回 null 时 <tt>ThreadFactory</tt> 未能创建线程，则执行程序将继续运行，但不能执行任何任务。 </dd><dt>保持活动时间</dt><dd>如果池中当前有多于 corePoolSize 的线程，则这些多出的线程在空闲时间超过 keepAliveTime 时将会终止（参见 <A HREF="ThreadPoolExecutor.html#getKeepAliveTime(java.util.concurrent.TimeUnit)"><CODE>getKeepAliveTime(java.util.concurrent.TimeUnit)</CODE></A>）。这提供了当池处于非活动状态时减少资源消耗的方法。如果池后来变得更为活动，则可以创建新的线程。也可以使用方法 <A HREF="ThreadPoolExecutor.html#setKeepAliveTime(long, java.util.concurrent.TimeUnit)"><CODE>setKeepAliveTime(long, java.util.concurrent.TimeUnit)</CODE></A> 动态地更改此参数。使用 <tt>Long.MAX_VALUE</tt> <A HREF="TimeUnit.html#NANOSECONDS"><CODE>TimeUnit.NANOSECONDS</CODE></A> 的值在关闭前有效地从以前的终止状态禁用空闲线程。 </dd><dt>排队</dt><dd>所有 <A HREF="BlockingQueue.html" title="java.util.concurrent 中的接口"><CODE>BlockingQueue</CODE></A> 都可用于传输和保持提交的任务。可以使用此队列与池大小进行交互： <ul><li> 如果运行的线程少于 corePoolSize，则 Executor 始终首选添加新的线程，而不进行排队。</li><li> 如果运行的线程等于或多于 corePoolSize，则 Executor 始终首选将请求加入队列，而不添加新的线程。</li> <li> 如果无法将请求加入队列，则创建新的线程，除非创建此线程超出 maximumPoolSize，在这种情况下，任务将被拒绝。</li> </ul>排队有三种通用策略： <ol><li> <em> 直接提交。</em>工作队列的默认选项是 <A HREF="SynchronousQueue.html" title="java.util.concurrent 中的类"><CODE>SynchronousQueue</CODE></A>，它将任务直接提交给线程而不保持它们。在此，如果不存在可用于立即运行任务的线程，则试图把任务加入队列将失败，因此会构造一个新的线程。此策略可以避免在处理可能具有内部依赖性的请求集合时出现锁定。直接提交通常要求无界 maximumPoolSizes 以避免拒绝新提交的任务。当命令以超过队列所能处理的平均数连续到达时，此策略允许无界线程具有增长的可能性。</li><li><em> 无界队列。</em>使用无界队列（例如，不具有预定义容量的 <A HREF="LinkedBlockingQueue.html" title="java.util.concurrent 中的类"><CODE>LinkedBlockingQueue</CODE></A>）将导致在所有 corePoolSize 线程都忙的情况下将新任务加入队列。这样，创建的线程就不会超过 corePoolSize。（因此，maximumPoolSize 的值也就无效了。）当每个任务完全独立于其他任务，即任务执行互不影响时，适合于使用无界队列；例如，在 Web 页服务器中。这种排队可用于处理瞬态突发请求，当命令以超过队列所能处理的平均数连续到达时，此策略允许无界线程具有增长的可能性。</li><li><em>有界队列。</em>当使用有限的 maximumPoolSizes 时，有界队列（如 <A HREF="ArrayBlockingQueue.html" title="java.util.concurrent 中的类"><CODE>ArrayBlockingQueue</CODE></A>）有助于防止资源耗尽，但是可能较难调整和控制。队列大小和最大池大小可能需要相互折衷：使用大型队列和小型池可以最大限度地降低 CPU 使用率、操作系统资源和上下文切换开销，但是可能导致人工降低吞吐量。如果任务频繁阻塞（例如，如果它们是 I/O 边界），则系统可能为超过您许可的更多线程安排时间。使用小型队列通常要求较大的池大小，CPU 使用率较高，但是可能遇到不可接受的调度开销，这样也会降低吞吐量。</li> </ol> </dd><dt>被拒绝的任务</dt><dd> 当 Executor 已经关闭，并且 Executor 将有限边界用于最大线程和工作队列容量，且已经饱和时，在方法 <A HREF="ThreadPoolExecutor.html#execute(java.lang.Runnable)"><CODE>execute(java.lang.Runnable)</CODE></A> 中提交的新任务将被<em>拒绝</em>。在以上两种情况下，<tt>execute</tt> 方法都将调用其 <A HREF="RejectedExecutionHandler.html" title="java.util.concurrent 中的接口"><CODE>RejectedExecutionHandler</CODE></A> 的 <A HREF="RejectedExecutionHandler.html#rejectedExecution(java.lang.Runnable, java.util.concurrent.ThreadPoolExecutor)"><CODE>RejectedExecutionHandler.rejectedExecution(java.lang.Runnable, java.util.concurrent.ThreadPoolExecutor)</CODE></A> 方法。下面提供了四种预定义的处理程序策略： <ol><li> 在默认的 <A HREF="ThreadPoolExecutor.AbortPolicy.html" title="java.util.concurrent 中的类"><CODE>ThreadPoolExecutor.AbortPolicy</CODE></A> 中，处理程序遭到拒绝将抛出运行时 <A HREF="RejectedExecutionException.html" title="java.util.concurrent 中的类"><CODE>RejectedExecutionException</CODE></A>。</li> <li> 在 <A HREF="ThreadPoolExecutor.CallerRunsPolicy.html" title="java.util.concurrent 中的类"><CODE>ThreadPoolExecutor.CallerRunsPolicy</CODE></A> 中，线程调用运行该任务的 <tt>execute</tt> 本身。此策略提供简单的反馈控制机制，能够减缓新任务的提交速度。</li><li> 在 <A HREF="ThreadPoolExecutor.DiscardPolicy.html" title="java.util.concurrent 中的类"><CODE>ThreadPoolExecutor.DiscardPolicy</CODE></A> 中，不能执行的任务将被删除。</li><li>在 <A HREF="ThreadPoolExecutor.DiscardOldestPolicy.html" title="java.util.concurrent 中的类"><CODE>ThreadPoolExecutor.DiscardOldestPolicy</CODE></A> 中，如果执行程序尚未关闭，则位于工作队列头部的任务将被删除，然后重试执行程序（如果再次失败，则重复此过程）。</li> </ol>定义和使用其他种类的 <A HREF="RejectedExecutionHandler.html" title="java.util.concurrent 中的接口"><CODE>RejectedExecutionHandler</CODE></A> 类也是可能的，但这样做需要非常小心，尤其是当策略仅用于特定容量或排队策略时。</dd><dt>挂钩方法</dt><dd>此类提供 <tt>protected</tt> 可重写的 <A HREF="ThreadPoolExecutor.html#beforeExecute(java.lang.Thread, java.lang.Runnable)"><CODE>beforeExecute(java.lang.Thread, java.lang.Runnable)</CODE></A> 和 <A HREF="ThreadPoolExecutor.html#afterExecute(java.lang.Runnable, java.lang.Throwable)"><CODE>afterExecute(java.lang.Runnable, java.lang.Throwable)</CODE></A> 方法，这两种方法分别在执行每个任务之前和之后调用。它们可用于操纵执行环境；例如，重新初始化 ThreadLocal、搜集统计信息或添加日志条目。此外，还可以重写方法 <A HREF="ThreadPoolExecutor.html#terminated()"><CODE>terminated()</CODE></A> 来执行 Executor 完全终止后需要完成的所有特殊处理。 <p>如果挂钩或回调方法抛出异常，则内部辅助线程将依次失败并突然终止。</dd> <dt>队列维护</dt><dd> 方法 <A HREF="ThreadPoolExecutor.html#getQueue()"><CODE>getQueue()</CODE></A> 允许出于监控和调试目的而访问工作队列。强烈反对出于其他任何目的而使用此方法。<A HREF="ThreadPoolExecutor.html#remove(java.lang.Runnable)"><CODE>remove(java.lang.Runnable)</CODE></A> 和 <A HREF="ThreadPoolExecutor.html#purge()"><CODE>purge()</CODE></A> 这两种方法可用于在取消大量已排队任务时帮助进行存储回收。</dd> </dl><p> <b>扩展示例</b>。此类的大多数扩展可以重写一个或多个受保护的挂钩方法。例如，下面是一个添加了简单的暂停/恢复功能的子类： <pre> class PausableThreadPoolExecutor extends ThreadPoolExecutor { private boolean isPaused; private ReentrantLock pauseLock = new ReentrantLock(); private Condition unpaused = pauseLock.newCondition(); public PausableThreadPoolExecutor(...) { super(...); } protected void beforeExecute(Thread t, Runnable r) { super.beforeExecute(t, r); pauseLock.lock(); try { while (isPaused) unpaused.await(); } catch(InterruptedException ie) { t.interrupt(); } finally { pauseLock.unlock(); } } public void pause() { pauseLock.lock(); try { isPaused = true; } finally { pauseLock.unlock(); } } public void resume() { pauseLock.lock();⌨️ 快捷键说明
复制代码Ctrl + C
搜索代码Ctrl + F
全屏模式F11
增大字号Ctrl + =
减小字号Ctrl + -
显示快捷键?