compact1, compact2, compact3

java.util.concurrent

Class AbstractExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

All Implemented Interfaces:

Executor， ExecutorService

已知直接子类：

ForkJoinPool， ThreadPoolExecutor

public abstract class AbstractExecutorService
extends Object
implements ExecutorService

提供 ExecutorService执行方法的默认实现。该类实现了 submit，使用 RunnableFuture返回 newTaskFor invokeAny和 invokeAll方法，在这个包提供的 FutureTask类默认。例如，对 submit(Runnable)实现创建一个相关的 RunnableFuture被执行并返回。子类可以重写 newTaskFor方法返回 RunnableFuture实现比其他 FutureTask。

扩展的例子。这里是一个班级的自定义ThreadPoolExecutor使用CustomTask类而不是默认的FutureTask素描：

 public class CustomThreadPoolExecutor extends ThreadPoolExecutor {

   static class CustomTask<V> implements RunnableFuture<V> {...}

   protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
       return new CustomTask<V>(c);
   }
   protected <V> RunnableFuture<V> newTaskFor(Runnable r, V v) {
       return new CustomTask<V>(r, v);
   }
   // ... add constructors, etc.
 }

从以下版本开始：

一点五

构造方法摘要

构造方法

Constructor and Description
AbstractExecutorService()

方法摘要

Modifier and Type	Method and Description
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks) 执行给定的任务，返回一个未来持有他们的状态和结果的列表时，所有的完整。
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 执行给定的任务，返回一个未来持有他们的状态和结果的列表时，所有的完成或超时到期，以先发生的。
<T> T	invokeAny(Collection<? extends Callable<T>> tasks) 执行给定的任务，返回已成功完成的结果（即，不抛出一个例外），如果任何。
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 执行给定的任务，返回一个成功完成的结果（即，不抛出异常），如果做了超时之前经过。
protected <T> RunnableFuture<T>	newTaskFor(Callable<T> callable) 返回给调用任务 RunnableFuture。
protected <T> RunnableFuture<T>	newTaskFor(Runnable runnable, T value) 返回一个 RunnableFuture为给定的运行与默认值。
<T> Future<T>	submit(Callable<T> task) 提交一个值返回任务执行，并返回一个表示任务挂起结果的未来。
Future<?>	submit(Runnable task) 提交执行一个Runnable任务并返回一个表示该任务的未来。
<T> Future<T>	submit(Runnable task, T result) 提交执行一个Runnable任务并返回一个表示该任务的未来。

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, isShutdown, isTerminated, shutdown, shutdownNow

Methods inherited from interface java.util.concurrent.Executor

execute

Constructor Detail

AbstractExecutorService

public AbstractExecutorService()

方法详细信息

newTaskFor

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

返回一个 RunnableFuture为给定的运行与默认值。

参数类型

T -给定的值的类型

参数

runnable的Runnable任务包

value -返回未来的默认值

结果

一个 RunnableFuture，运行时，将运行的基本运行和它作为一个 Future，将给定的值作为结果为基本任务取消

从以下版本开始：

一点六

newTaskFor

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

返回给调用任务 RunnableFuture。

参数类型

T -可调用的结果的类型

参数

callable -可赎回的任务包

结果

一个 RunnableFuture，运行时，会调用底层可赎回的，作为一个 Future，产量将可调用的结果作为其结果为基本任务取消

从以下版本开始：

一点六

submit

public Future<?> submit(Runnable task)

从接口复制的描述： ExecutorService

提交执行一个Runnable任务并返回一个表示该任务的未来。未来的 get方法将返回 null在成功完成。

Specified by:

submit 接口 ExecutorService

参数

task -任务提交

结果

一个即将完成的任务的未来

异常

RejectedExecutionException如果任务不能按计划执行

NullPointerException -如果任务是空的

submit

public <T> Future<T> submit(Runnable task,
                            T result)

从接口复制的描述： ExecutorService

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

Specified by:

submit 接口 ExecutorService

参数类型

T -结果的类型

参数

task -任务提交

result -结果返回

结果

一个即将完成的任务的未来

异常

RejectedExecutionException如果任务不能按计划执行

NullPointerException -如果任务是空的

submit

public <T> Future<T> submit(Callable<T> task)

从接口复制的描述： ExecutorService

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

如果你想立即阻塞等待一个任务，你可以使用表格result = exec.submit(aCallable).get();结构

注：本Executors类包含一组方法，可以将其他一些常见的闭合状物体，例如，PrivilegedAction到Callable形式可以提交。

Specified by:

submit 接口 ExecutorService

参数类型

T -任务类型结果

参数

task -任务提交

结果

一个即将完成的任务的未来

异常

RejectedExecutionException如果任务不能按计划执行

NullPointerException -如果任务是空的

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
                throws InterruptedException,
                       ExecutionException

从接口复制的描述： ExecutorService

执行给定的任务，返回已成功完成的结果（即，不抛出一个例外），如果任何。在正常或异常的情况下，未完成的任务被取消。此方法的结果是不确定的，如果给定的集合被修改，而这个操作正在进行中。

Specified by:

invokeAny 接口 ExecutorService

参数类型

从任务 T -返回值的类型

参数

tasks -任务的集合

结果

任务由一个返回的结果

异常

InterruptedException如果中断等待

ExecutionException -如果没有任务圆满完成

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                       long timeout,
                       TimeUnit unit)
                throws InterruptedException,
                       ExecutionException,
                       TimeoutException

从接口复制的描述： ExecutorService

执行给定的任务，返回一个成功完成的结果（即，不抛出异常），如果做了超时之前经过。在正常或异常的情况下，未完成的任务被取消。此方法的结果是不确定的，如果给定的集合被修改，而这个操作正在进行中。

Specified by:

invokeAny 接口 ExecutorService

参数类型

T -值的类型从任务返回

参数

tasks -任务的集合

timeout -最大等待时间

unit - timeout参数的时间单位

结果

任务由一个返回的结果

异常

InterruptedException如果中断等待

ExecutionException -如果没有任务圆满完成

TimeoutException -如果超时之前经过的任何任务圆满完成

invokeAll

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

从接口复制的描述： ExecutorService

执行给定的任务，返回一个未来持有他们的状态和结果的列表时，所有的完整。 Future.isDone()是 true为返回的列表中的每个元素。请注意，一个完成的任务可能会被终止或通过抛出一个异常。此方法的结果是不确定的，如果给定的集合被修改，而这个操作正在进行中。

Specified by:

invokeAll 接口 ExecutorService

参数类型

从任务 T -返回值的类型

参数

tasks -任务的集合

结果

一个代表任务的期货列表，在给定的任务列表的迭代器所产生的相同的顺序顺序中，每一个都完成了

异常

InterruptedException如果中断而等待，在这种情况下，未完成的任务被取消

invokeAll

public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                     long timeout,
                                     TimeUnit unit)
                              throws InterruptedException

从接口复制的描述： ExecutorService

执行给定的任务，返回一个未来持有他们的状态和结果的列表时，所有的完成或超时到期，以先发生的。 Future.isDone()是 true为返回的列表中的每个元素。返回后，未完成的任务被取消。请注意，一个完成的任务可能会被终止或通过抛出一个异常。此方法的结果是不确定的，如果给定的集合被修改，而这个操作正在进行中。

Specified by:

invokeAll 接口 ExecutorService

参数类型

T -值的类型从任务返回

参数

tasks -任务的集合

timeout -最大等待时间

unit - timeout参数的时间单位

结果

在给定任务列表中的迭代器所产生的相同顺序顺序中的一个表示任务的列表。如果操作没有超时，每个任务都将完成。如果它确实有时间，一些这些任务将不会完成。

异常

InterruptedException如果中断而等待，在这种情况下，未完成的任务被取消