AbstractExecutorService

目录搜索

文字

概述

软件包

类

使用

树

已过时

索引

帮助

Java^TM 2 Platform
Standard Ed. 6

上一个类 下一个类

框架 无框架

摘要：嵌套 | 字段 | 构造方法 | 方法

详细信息：字段 | 构造方法 | 方法

java.util.concurrent
类 AbstractExecutorService

java.lang.Object
  java.util.concurrent.AbstractExecutorService

所有已实现的接口：: Executor, ExecutorService

直接已知子类：: ThreadPoolExecutor

public abstract class AbstractExecutorService
extends Object
implements ExecutorService

提供 ExecutorService 执行方法的默认实现。此类使用 newTaskFor 返回的 RunnableFuture 实现 submit、invokeAny 和 invokeAll 方法，默认情况下，RunnableFuture 是此包中提供的 FutureTask 类。例如，submit(Runnable) 的实现创建了一个关联 RunnableFuture 类，该类将被执行并返回。子类可以重写 newTaskFor 方法，以返回 FutureTask 之外的 RunnableFuture 实现。

扩展示例。以下是一个类的简要介绍，该类定制 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.
 }

从以下版本开始：: 1.5

构造方法摘要
`AbstractExecutorService()`

方法摘要




<T> List<Future<T>>

invokeAll(Collection<? extends Callable<T>> tasks)
执行给定的任务，当所有任务完成时，返回保持任务状态和结果的 Future 列表。




<T> List<Future<T>>

invokeAll(Collection<? extends Callable<T>> tasks,
          long timeout,
          TimeUnit unit)

执行给定的任务，当所有任务完成或超时期满时（无论哪个首先发生），返回保持任务状态和结果的 Future 列表。




<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)
提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。




<T> Future<T>

submit(Runnable task,
       T result)

提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。

从类 java.lang.Object 继承的方法
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

从接口 java.util.concurrent.ExecutorService 继承的方法
`awaitTermination, isShutdown, isTerminated, shutdown, shutdownNow`

从接口 java.util.concurrent.Executor 继承的方法
`execute`

构造方法详细信息

public AbstractExecutorService()

方法详细信息

newTaskFor

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

为给定可运行任务和默认值返回一个 RunnableFuture。

参数：: runnable - 将被包装的可运行任务; value - 用于所返回的将来任务的默认值

返回：

一个 RunnableFuture，在运行的时候，它将运行底层可运行任务，作为 Future 任务，它将生成给定值作为其结果，并为底层任务提供取消操作。

从以下版本开始：

1.6

newTaskFor

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

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

参数：: callable - 将包装的可调用任务
返回：: 一个 RunnableFuture，在运行的时候，它将调用底层可调用任务，作为 Future 任务，它将生成可调用的结果作为其结果，并为底层任务提供取消操作。
从以下版本开始：: 1.6

submit

public Future<?> submit(Runnable task)

从接口 ExecutorService 复制的描述

提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。该 Future 的 get 方法在成功完成时将会返回 null。

指定者：: 接口 ExecutorService 中的 submit

参数：: task - 要提交的任务
返回：: 表示任务等待完成的 Future

submit

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

从接口 ExecutorService 复制的描述

提交一个 Runnable 任务用于执行，并返回一个表示该任务的 Future。该 Future 的 get 方法在成功完成时将会返回给定的结果。

指定者：: 接口 ExecutorService 中的 submit

参数：: task - 要提交的任务; result - 返回的结果

返回：

表示任务等待完成的 Future

submit

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

从接口 ExecutorService 复制的描述

提交一个返回值的任务用于执行，返回一个表示任务的未决结果的 Future。该 Future 的 get 方法在成功完成时将会返回该任务的结果。

如果想立即阻塞任务的等待，则可以使用 result = exec.submit(aCallable).get(); 形式的构造。

注：Executors 类包括了一组方法，可以转换某些其他常见的类似于闭包的对象，例如，将 PrivilegedAction 转换为 Callable 形式，这样就可以提交它们了。

指定者：: 接口 ExecutorService 中的 submit

参数：: task - 要提交的任务
返回：: 表示任务等待完成的 Future

invokeAny

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

从接口 ExecutorService 复制的描述

执行给定的任务，如果某个任务已成功完成（也就是未抛出异常），则返回其结果。一旦正常或异常返回后，则取消尚未完成的任务。如果此操作正在进行时修改了给定的 collection，则此方法的结果是不确定的。

指定者：: 接口 ExecutorService 中的 invokeAny

参数：: tasks - 任务 collection
返回：: 某个任务返回的结果
抛出：: InterruptedException - 如果等待时发生中断; ExecutionException - 如果没有任务成功完成

invokeAny

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

从接口 ExecutorService 复制的描述

执行给定的任务，如果在给定的超时期满前某个任务已成功完成（也就是未抛出异常），则返回其结果。一旦正常或异常返回后，则取消尚未完成的任务。如果此操作正在进行时修改了给定的 collection，则此方法的结果是不确定的。

指定者：: 接口 ExecutorService 中的 invokeAny

参数：: tasks - 任务 collection; timeout - 最长等待时间; unit - timeout 参数的时间单位

返回：

某个任务返回的结果

抛出：

InterruptedException - 如果等待时发生中断

ExecutionException - 如果没有任务成功完成

TimeoutException - 如果在所有任务成功完成之前给定的超时期满

invokeAll

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

从接口 ExecutorService 复制的描述

执行给定的任务，当所有任务完成时，返回保持任务状态和结果的 Future 列表。返回列表的所有元素的 Future.isDone() 为 true。注意，可以正常地或通过抛出异常来终止已完成 任务。如果正在进行此操作时修改了给定的 collection，则此方法的结果是不确定的。

指定者：: 接口 ExecutorService 中的 invokeAll

参数：: tasks - 任务 collection
返回：: 表示任务的 Future 列表，列表顺序与给定任务列表的迭代器所生成的顺序相同，每个任务都已完成。
抛出：: InterruptedException - 如果等待时发生中断，在这种情况下取消尚未完成的任务。

invokeAll

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

从接口 ExecutorService 复制的描述

执行给定的任务，当所有任务完成或超时期满时（无论哪个首先发生），返回保持任务状态和结果的 Future 列表。返回列表的所有元素的 Future.isDone() 为 true。一旦返回后，即取消尚未完成的任务。注意，可以正常地或通过抛出异常来终止已完成 任务。如果此操作正在进行时修改了给定的 collection，则此方法的结果是不确定的。

指定者：: 接口 ExecutorService 中的 invokeAll

参数：: tasks - 任务 collection; timeout - 最长等待时间; unit - timeout 参数的时间单位

返回：

表示任务的 Future 列表，列表顺序与给定任务列表的迭代器所生成的顺序相同。如果操作未超时，则已完成所有任务。如果确实超时了，则某些任务尚未完成。

抛出：

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

概述

软件包

类

使用

树

已过时

索引

帮助

Java^TM 2 Platform
Standard Ed. 6

上一个类 下一个类

框架 无框架

摘要：嵌套 | 字段 | 构造方法 | 方法

详细信息：字段 | 构造方法 | 方法

提交错误或意见
有关更多的 API 参考资料和开发人员文档，请参阅 Java 2 SDK SE 开发人员文档。该文档包含更详细的、面向开发人员的描述，以及总体概述、术语定义、使用技巧和工作代码示例。

java.util.concurrent 类 AbstractExecutorService