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 ， invokeAny和invokeAll使用方法RunnableFuture通过返回newTaskFor ，其默认为FutureTask类此包中提供。 例如，submit(Runnable)的submit(Runnable)创建一个执行和返回的关联的RunnableFuture 。 子类可以覆盖newTaskFor方法以返回RunnableFuture FutureTask的FutureTask 。

扩展示例 。 以下是自定义ThreadPoolExecutor使用CustomTask类而不是默认值FutureTask类的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. } 

从以下版本开始：

1.5

构造方法摘要

构造方法

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。
Future<?>	submit(Runnable task) 提交一个可运行的任务执行，并返回一个表示该任务的未来。
<T> Future<T>	submit(Runnable task, T result) 提交一个可运行的任务执行，并返回一个表示该任务的未来。

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

构造方法详细信息

AbstractExecutorService

public AbstractExecutorService()

方法详细信息

newTaskFor

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

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

参数类型

T - 给定值的类型

参数

runnable - 正在包装的可运行任务

value - 返回的未来的默认值

结果

一个 RunnableFuture ，当运行时，将运行底层的可运行程序，作为一个 Future ，它将产生给定的值作为其结果，并提供取消基础任务

从以下版本开始：

1.6

newTaskFor

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

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

参数类型

T - 可调用结果的类型

参数

callable - 正在包装的可调用任务

结果

一个 RunnableFuture ，当运行时，将调用底层可调用，作为 Future将作为其结果产生可调用的结果，并提供取消基础任务

从以下版本开始：

1.6

submit

public Future<?> submit(Runnable task)

说明从界面： ExecutorService复制

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

Specified by:

submit在界面 ExecutorService

参数

task - 要提交的任务

结果

一个未来的代表，待完成任务

异常

RejectedExecutionException - 如果任务无法安排执行

NullPointerException - 如果任务为空

submit

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

说明从界面： ExecutorService复制

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

Specified by:

submit在界面 ExecutorService

参数类型

T - 结果的类型

参数

task - 要提交的任务

result - 结果返回

结果

一个未来的代表，待完成任务

异常

RejectedExecutionException - 如果任务无法安排执行

NullPointerException - 如果任务为空

submit

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

说明从界面： ExecutorService复制

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

如果您想立即阻止等待任务，您可以使用result = exec.submit(aCallable).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 - 超时参数的时间单位

结果

其中一个任务返回的结果

异常

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 - 超时参数的时间单位

结果

一个表示任务的期货列表，按照给定任务列表的迭代器生成的顺序。 如果操作没有超时，每个任务都会完成。 如果超时，其中一些任务将不会完成。

异常

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