Интерфейс Executor

public interface Executor

Объект, выполняющий переданные задачи Runnable. Этот интерфейс позволяет отделить передачу задач от механизмов их выполнения, включая детали использования потоков, планирования и т. д. Обычно Executor используют вместо явного создания потоков. Например, вместо вызова new Thread(new RunnableTask()).start() для каждой задачи из набора можно использовать:

Executor executor = anExecutor();
executor.execute(new RunnableTask1());
executor.execute(new RunnableTask2());
...

Однако интерфейс Executor не требует строгого асинхронного выполнения. В простейшем случае исполнитель может немедленно выполнить переданную задачу в потоке вызывающего кода:

class DirectExecutor implements Executor {
  public void execute(Runnable r) {
    r.run();
  }
}

Чаще задачи выполняются в потоке, отличном от потока вызывающего кода. Приведенный ниже исполнитель создает новый поток для каждой задачи.

class ThreadPerTaskExecutor implements Executor {
  public void execute(Runnable r) {
    new Thread(r).start();
  }
}

Многие реализации Executor накладывают те или иные ограничения на порядок и время планирования задач. Приведенный ниже исполнитель последовательно передает задачи второму исполнителю, демонстрируя составной исполнитель.

class SerialExecutor implements Executor {
  final Queue<Runnable> tasks = new ArrayDeque<>();
  final Executor executor;
  Runnable active;

  SerialExecutor(Executor executor) {
    this.executor = executor;
  }

  public synchronized void execute(Runnable r) {
    tasks.add(() -> {
      try {
        r.run();
      } finally {
        scheduleNext();
      }
    });
    if (active == null) {
      scheduleNext();
    }
  }

  protected synchronized void scheduleNext() {
    if ((active = tasks.poll()) != null) {
      executor.execute(active);
    }
  }
}

Реализации Executor, предоставляемые этим пакетом, реализуют ExecutorService, представляющий собой более развитый интерфейс. Класс ThreadPoolExecutor предоставляет расширяемую реализацию пула потоков. Класс Executors предоставляет удобные фабричные методы для этих исполнителей.

Эффекты согласованности памяти: действия в потоке, выполненные до передачи объекта Runnable исполнителю Executor, предшествуют началу его выполнения, возможно, в другом потоке.