ForkJoinPool

defaultForkJoinWorkerThreadFactory

ForkJoinPool.ForkJoinWorkerThreadFactory defaultForkJoinWorkerThreadFactory

创建一个新的ForkJoinWorkerThread。 除非在ForkJoinPool构造函数中重写，否则将使用此工厂。

ForkJoinPool

ForkJoinPool ()

创建 ForkJoinPool ，并行度等于 availableProcessors() ，使用 default thread factory ，no UncaughtExceptionHandler和非异步LIFO处理模式。

ForkJoinPool

ForkJoinPool (int parallelism)

创建 ForkJoinPool用指示的并行层面， default thread factory ，没有UncaughtExceptionHandler的，和非异步LIFO处理模式。

ForkJoinPool

ForkJoinPool (int parallelism, 
                ForkJoinPool.ForkJoinWorkerThreadFactory factory, 
                Thread.UncaughtExceptionHandler handler, 
                boolean asyncMode)

用给定的参数创建一个 ForkJoinPool 。

awaitQuiescence

boolean awaitQuiescence (long timeout, 
                TimeUnit unit)

如果由在该池中运行的ForkJoinTask调用，则等效于helpQuiesce() 。 否则，等待和/或尝试协助执行任务，直到该池isQuiescent()或指示的超时过去。

awaitTermination

boolean awaitTermination (long timeout, 
                TimeUnit unit)

阻塞，直到所有任务在关闭请求之后所有任务都已完成执行，或发生超时，或当前线程中断，以先发生者为准。 由于commonPool()在程序关闭之前永不终止，因此应用于公共池时，此方法等同于awaitQuiescence(long, TimeUnit)但始终返回false 。

commonPool

ForkJoinPool commonPool ()

返回公共池实例。 这个池是静态构建的; 其运行状态不受shutdown()或shutdownNow()尝试影响。 然而，该池和任何正在进行的处理在程序exit(int)自动终止。 任何依赖异步任务处理在程序终止前完成的程序都应该在退出之前调用commonPool(). awaitQuiescence 。

execute

void execute (Runnable task)

execute

void execute (ForkJoinTask<?> task)

安排（异步）执行给定的任务。

getActiveThreadCount

int getActiveThreadCount ()

返回当前正在窃取或执行任务的线程数的估计值。 此方法可能会高估活动线程的数量。

getAsyncMode

boolean getAsyncMode ()

如果此池使用本地先进先出调度模式执行未加入的分支任务，则返回 true 。

getCommonPoolParallelism

int getCommonPoolParallelism ()

返回公共池的目标并行度级别。

getFactory

ForkJoinPool.ForkJoinWorkerThreadFactory getFactory ()

返回用于构建新工人的工厂。

getParallelism

int getParallelism ()

返回此池的目标并行度级别。

getPoolSize

int getPoolSize ()

返回已开始但尚未终止的工作线程数。 当创建线程时，此方法返回的结果可能与getParallelism()不同， getParallelism()在其他人协作阻止时保持并行性。

getQueuedSubmissionCount

int getQueuedSubmissionCount ()

返回提交给该池但尚未开始执行的任务数量的估计值。 此方法可能需要与提交次数成比例的时间。

getQueuedTaskCount

long getQueuedTaskCount ()

返回工作线程当前在队列中保留的任务总数的估计值（但不包括提交给池的任务尚未开始执行的任务）。 该值只是一个近似值，通过遍历池中的所有线程获得。 此方法可能对调整任务粒度很有用。

getRunningThreadCount

int getRunningThreadCount ()

返回未阻止等待加入任务或其他受管同步的工作线程数量的估计值。 此方法可能会高估运行线程的数量。

getStealCount

long getStealCount ()

返回另一个线程工作队列中被盗任务总数的估计值。 当游泳池不静止时，报告的值低估了实际的总抢断次数。 该值对于监视和调整fork / join程序非常有用：通常，窃取计数应足够高以保持线程繁忙，但又足够低以避免跨线程的开销和争用。

getUncaughtExceptionHandler

Thread.UncaughtExceptionHandler getUncaughtExceptionHandler ()

返回由于执行任务时遇到的不可恢复的错误而终止的内部工作线程的处理程序。

hasQueuedSubmissions

boolean hasQueuedSubmissions ()

返回 true如果有任何任务提交给该池尚未开始执行。

invoke

T invoke (ForkJoinTask<T> task)

执行给定的任务，完成后返回结果。 如果计算遇到未检查的异常或错误，则将其作为此调用的结果重新生成。 突发异常的行为与常规异常相同，但在可能的情况下，包含当前线程以及实际遇到异常的线程的堆栈跟踪（例如，使用ex.printStackTrace()显示）; 最低限度只有后者。

invokeAll

List<Future<T>> invokeAll (Collection<? extends Callable<T>> tasks)

执行给定的任务，返回一份持有其状态和结果的期货清单，当全部完成时。 isDone()对于返回列表的每个元素都是true 。 请注意， 完成的任务可能正常结束或通过抛出异常终止。 如果在进行此操作时修改了给定集合，则此方法的结果未定义。

isQuiescent

boolean isQuiescent ()

如果所有工作线程当前空闲，则返回true 。 闲置的工作者是无法获得任务来执行的工作者，因为没有人可以从其他线程窃取，并且没有待处理的提交到池中。 这种方法是保守的; 它可能不会在所有线程空闲时立即返回true ，但如果线程保持不活动状态，则最终会变为真。

isShutdown

boolean isShutdown ()

如果此池已关闭，则返回 true 。

isTerminated

boolean isTerminated ()

如果所有任务都在关闭后完成，则返回 true 。

isTerminating

boolean isTerminating ()

如果终止过程已经开始但尚未完成，则返回true 。 该方法可能对调试有用。 true报告的关闭时间足够长，可能表示提交的任务已忽略或抑制中断，或正在等待I / O，导致此执行程序未正确终止。 （请参阅ForkJoinTask类的ForkJoinTask说明，指出任务通常不应导致阻塞操作，但如果它们这样做，则必须在中断时中止它们。）

managedBlock

void managedBlock (ForkJoinPool.ManagedBlocker blocker)

运行给定的可能阻塞的任务。 当running in a ForkJoinPool时 ，此方法可能会安排备用线程在必要时被激活，以确保足够的并行性，而当前线程在blocker.block()被阻止。

此方法重复调用blocker.isReleasable()和blocker.block()直到任一方法返回true 。 对每一个呼叫blocker.block()由一个呼叫之前blocker.isReleasable()一个返回false 。

如果不在ForkJoinPool中运行，则此方法在行为上等同于

 while (!blocker.isReleasable())
   if (blocker.block())
     break;

shutdown

void shutdown ()

可能会启动有序关闭，其中先前提交的任务将执行，但不会接受任何新任务。 如果这是commonPool() ，则调用对执行状态没有影响，如果已经关闭，则不会有其他影响。 在此方法过程中同时提交的任务可能会或可能不会被拒绝。

shutdownNow

List<Runnable> shutdownNow ()

可能尝试取消和/或停止所有任务，并拒绝所有随后提交的任务。 如果这是commonPool() ，则调用对执行状态没有影响，如果已经关闭，则不会有其他影响。 否则，在此方法过程中同时提交或执行的任务可能会或可能不会被拒绝。 此方法取消现有和未执行的任务，以允许在存在任务依赖关系时终止。 所以该方法总是返回一个空列表（与其他一些Executors不同）。

submit

ForkJoinTask<T> submit (Callable<T> task)

提交执行的返回值任务，并返回表示未完成任务结果的Future。 未来的get方法将在成功完成后返回任务的结果。

如果您想立即阻止等待任务，可以使用表单 result = exec.submit(aCallable).get();

注意： Executors类包含一组方法，可以将一些其他常见闭合对象（例如， PrivilegedAction为 Callable表单，以便它们可以提交。

submit

ForkJoinTask<T> submit (ForkJoinTask<T> task)

提交ForkJoinTask执行。

submit

ForkJoinTask<?> submit (Runnable task)

提交可执行的任务并返回表示该任务的Future。 成功完成后，未来get方法将返回null 。

submit

ForkJoinTask<T> submit (Runnable task, 
                T result)

提交可执行的任务并返回表示该任务的Future。 未来的get方法将在成功完成后返回给定的结果。

toString

String toString ()

返回标识此池的字符串及其状态，包括运行状态，并行级别以及工作和任务计数的指示。

drainTasksTo

int drainTasksTo (Collection<? super ForkJoinTask<?>> c)

从调度队列中删除所有未执行的提交和分派任务，并将它们添加到给定集合中，而不更改其执行状态。 这些可能包括人工生成或包装的任务。 此方法旨在仅在池已知为静态时才被调用。 其他时间的调用可能不会删除所有任务。 尝试将元素添加到集合c遇到的故障可能导致元素不在任何集合中，或者在引发关联的异常时集合中的任何一个或两个集合。 如果在操作过程中修改了指定的集合，则此操作的行为未定义。

newTaskFor

RunnableFuture<T> newTaskFor (Runnable runnable, 
                T value)

针对给定的可运行和默认值返回 RunnableFuture 。

newTaskFor

RunnableFuture<T> newTaskFor (Callable<T> callable)

为给定的可调用任务返回 RunnableFuture 。

pollSubmission

ForkJoinTask<?> pollSubmission ()

删除并返回下一个未执行的提交（如果有）。 此方法可能对此类的扩展有用，该类会在具有多个池的系统中重新分配工作。