ExecutorService 接口
java.util.concurrent.ExecutorService 接口是 Executor 接口的子接口，并添加了管理各个任务和执行器本身生命周期的功能。
ExecutorService 方法
| Sr.No. | 方法及描述 |
|---|---|
| 1 | boolean awaitTermination(long timeout, TimeUnit unit) 阻塞，直到所有任务在关闭请求后完成执行，或者发生超时，或者当前线程被中断，以先发生者为准。 |
| 2 | <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 执行给定的任务，在全部完成时返回保存其状态和结果的 Future 列表。 |
| 3 | <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 执行给定的任务，当全部完成或超时到期(以先发生者为准)时，返回保存其状态和结果的 Future 列表。 |
| 4 | <T> T invokeAny(Collection<? extends Callable<T>> tasks) 执行给定的任务，返回已成功完成的任务的结果(即，不引发异常)(如果有)。 |
| 5 | <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 执行给定的任务，返回已成功完成的任务的结果(即，不引发异常)(如果在给定超时之前有任何操作)。 |
| 6 | boolean isShutdown() 如果该执行器已关闭，则返回 true。 |
| 7 | boolean isTerminated() 如果关闭后所有任务均已完成，则返回 true。 |
| 8 | void shutdown() 启动有序关闭，其中执行先前提交的任务，但不会接受新任务。 |
| 9 | List<Runnable> shutdownNow() 尝试停止所有正在执行的任务，停止正在等待的任务的处理，并返回正在等待执行的任务的列表。 |
| 10 | <T> Future<T> submit(Callable<T> task) 提交一个返回值的任务来执行，并返回一个代表任务待处理结果的 Future。 |
| 11 | Future<?> submit(Runnable task) 提交一个 Runnable 任务来执行并返回一个代表该任务的 Future。 |
| 12 | <T> Future<T> submit(Runnable task, T result) 提交一个 Runnable 任务来执行并返回一个代表该任务的 Future。 |
示例
以下 TestThread 程序显示了 ExecutorService 接口在基于线程的环境中的用法。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class TestThread {
public static void main(final String[] arguments) throws InterruptedException {
ExecutorService executor = Executors.newSingleThreadExecutor();
try {
executor.submit(new Task());
System.out.println("Shutdown executor");
executor.shutdown();
executor.awaitTermination(5, TimeUnit.SECONDS);
} catch (InterruptedException e) {
System.err.println("tasks interrupted");
} finally {
if (!executor.isTerminated()) {
System.err.println("cancel non-finished tasks");
}
executor.shutdownNow();
System.out.println("shutdown finished");
}
}
static class Task implements Runnable {
public void run() {
try {
Long duration = (long) (Math.random() * 20);
System.out.println("Running Task!");
TimeUnit.SECONDS.sleep(duration);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
这将产生以下结果。
输出
Shutdown executor Running Task! shutdown finished cancel non-finished tasks java.lang.InterruptedException: sleep interrupted at java.lang.Thread.sleep(Native Method) at java.lang.Thread.sleep(Thread.java:302) at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:328) at TestThread$Task.run(TestThread.java:39) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439) at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) at java.util.concurrent.FutureTask.run(FutureTask.java:138) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918) at java.lang.Thread.run(Thread.java:662)
