一文搞懂Executor执行器和线程池的关系，整体介绍其任务执行/调度体系：ThreadPoolExecutor、ScheduledExecutorService（上）

public interface Executor {
  // @since 1.5
  void execute(Runnable command);
}

@Test
public void fun1() {
    String mainThreadName = Thread.currentThread().getName();
    System.out.println("----------主线程[" + mainThreadName + "]开始----------");
    // 自己定义一个同步执行器
    Executor syncExecutor = (Runnable command) -> command.run();
    // 提交任务
    syncExecutor.execute(() -> {
        String currThreadName = Thread.currentThread().getName();
        System.out.println("线程[" + currThreadName + "] 我是同步执行的...");
    });
}

@Test
public void fun2() throws InterruptedException {
    String mainThreadName = Thread.currentThread().getName();
    System.out.println("----------主线程[" + mainThreadName + "]开始----------");
    // 自己定义一个异步执行器
    Executor asyncExecutor = (Runnable command) -> new Thread(command).start();
    // 提交任务
    asyncExecutor.execute(() -> {
        String currThreadName = Thread.currentThread().getName();
        System.out.println("线程[" + currThreadName + "] 我是异步执行的...");
    });
    TimeUnit.SECONDS.sleep(1);
}

// @since 1.5
public interface ExecutorService extends Executor {
  // 关闭。执行已经提交的任务，但不接受新任务。
  // 此方法用于关闭不需要使用的执行器，内部会做资源回收的操作，如回收线程池
  void shutdown();
  // 试图停止所有正在执行的活动任务，暂停处理正在等待的任务，并返回等待执行的任务列表
  // 此方法一般不使用
  List<Runnable> shutdownNow();
  // 执行器是否已经被关闭
  boolean isShutdown();
  // 只有当shutdown()或者shutdownNow()被调用，而且所有任务都执行完成后才会返回true
  boolean isTerminated();
  // 阻塞。直到所有的任务都被执行完，或者超时
  boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException;
  // =====下面为任务提交方法(使用Future跟踪任务执行情况)=====
  // 以下三个是最最最最最最最常用的方法：执行任务
  // Callable任务有返回值。所以Future.get()的时候可以拿到此返回值
  <T> Future<T> submit(Callable<T> task);
  // Runnable任务。执行完后Future.get()永远返回的是result这个值
  <T> Future<T> submit(Runnable task, T result);
  // 执行完后Future.get()永远返回的是null
  Future<?> submit(Runnable task);
  // 这几个方法在**批量执行**或**多选一**的业务场景中非常方便。
  // invokeAll：所有任务都完成（包括成功/被中断/超时）后才会返回，所以它会阻塞哦（时间由最长的决定）
  // invokeAny()在任意一个任务成功（被中断/超时）后就会返回，只需要成功一个就返回（时间由最短的决定）
  <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;
}