1
2
3
4
5
public interface Executor {
    //执行指定的任务，不一定在Executor本身所在的线程执行该任务，也可以通过新的线程或者线程池来执行。
    //事实上，大部分情况都应该通过新的线程或者线程池执行该任务
    void execute(Runnable command);
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
public interface ExecutorService extends Executor {
    /**
    * 启动一次顺序关闭，执行已经提交的任务，但不接受新的任务
    */
    void shutdown();

    /**
    * 尝试终止正在执行的任务，终止正在等待的任务，返回正在等待执行的任务列表
    * 没有办法保证能够停止正在运行的任务，如果线程不响应中断的话，这些线程可能永远不会终止
    */
    List<Runnable> shutdownNow();

    //返回该执行者是否已经关闭
    boolean isShutdown();

    //如果关闭后所有任务都已完成，返回true
    //只有先调用shotdown或shutdownNow，该方法才可能返回true
    boolean isTerminated();

    //收到shutdown请求后，该执行者阻塞，直到任务完成或者超时或者当前线程被中断
    //如果该执行者正常终止返回true，如果超时返回false
    //如果线程被中断，抛出中断异常
    boolean awaitTermination(long timeout, TimeUnit unit)
        throws InterruptedException;

    /**
    * 提交一个有返回值的任务，返回一个带有任务执行结果的对象
    * 任务执行结果Future的get方法会阻塞，直到该任务执行完成
    * 如果执行者不能调度执行该任务，抛出拒绝执行异常
    */
    <T> Future<T> submit(Callable<T> task);

    /**
    * 该方法和上面的方法类似，因为Runnable是没有返回值的，因此这里加了另一个参数result
    * 表示任务的返回结果
    */
    <T> Future<T> submit(Runnable task, T result);

    /**
    * 提交一个没有返回值的任务，返回代表任务返回结果的Future对象
    */
    Future<?> submit(Runnable task);

    //执行任务列表，返回任务的执行结果列表，返回任务结果的顺序和执行任务的顺序一致
    <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
        throws InterruptedException;

    //执行带超时时间的任务列表，返回任务执行结果，如果任务超时，执行结果就是未完成
    <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                  long timeout, TimeUnit unit)
        throws InterruptedException;

    //执行给定的任务列表，返回其中一个已经完成的任务结果
    //如果没有任务完成，抛出执行异常
    <T> T invokeAny(Collection<? extends Callable<T>> tasks)
        throws InterruptedException, ExecutionException;

    //执行给定的任务，如果在超时时间内某个任务已经成功完成，则返回该结果
    <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                    long timeout, TimeUnit unit)
        throws InterruptedException, ExecutionException, TimeoutException;
}