多线程（22）Executor`框架

Executor框架是Java提供的一套高级的线程管理机制，它在java.util.concurrent包中。这个框架旨在简化并发编程，提供了线程池管理、任务调度、异步计算等功能，让开发者能够更加专注于任务的执行逻辑，而不是线程的管理和调度。

核心接口和类

1. `Executor`

Executor接口是Executor框架的基础，它仅定义了一个方法execute(Runnable command)，这个方法用于在未来某个时间执行给定的命令。这个命令是一个Runnable对象，代表一个无返回值的任务。

2. `ExecutorService`

ExecutorService是Executor的子接口，提供了更复杂的功能，包括任务生命周期管理（比如关闭Executor）和任务结果追踪（通过Future）。它定义了一系列方法，用于提交不同类型的任务，这些任务可以是Callable或Runnable类型。

3. `ScheduledExecutorService`

ScheduledExecutorService是ExecutorService的子接口，能够让你安排任务在将来的某个时间执行，或者定期执行。

4. `ThreadPoolExecutor`

ThreadPoolExecutor是ExecutorService接口的一个实现，提供了一个灵活的线程池。线程池可以减少在执行大量异步任务时创建和销毁线程的开销。

5. `ForkJoinPool`

ForkJoinPool是专为大量短暂任务设计的一个线程池实现，使用“工作窃取”模式来优化任务的处理过程。

工作原理和关键特征

任务提交与执行分离：开发者只需定义和提交任务，Executor框架负责任务的执行、线程管理、任务调度等。
线程复用：通过线程池管理线程，可以复用已存在的线程，避免频繁创建和销毁线程的高昂成本。
控制任务执行策略：可以自定义线程池的大小、线程存活时间、任务队列大小等，以适应不同的应用需求。
提供异步计算能力：通过Future接口，可以跟踪异步任务的执行状态，并在任务完成时获取其结果。

使用示例

以下是一个简单的ExecutorService使用示例，演示如何提交任务并获取结果：

import java.util.concurrent.*;public class ExecutorExample {public static void main(String[] args) throws ExecutionException, InterruptedException {// 创建一个固定大小的线程池ExecutorService executor = Executors.newFixedThreadPool(2);// 提交一个Callable任务Future<Integer> future = executor.submit(() -> {System.out.println("Executing task...");TimeUnit.SECONDS.sleep(1);return 123;});// 阻塞等待任务完成，并获取结果Integer result = future.get();System.out.println("Result: " + result);// 关闭ExecutorServiceexecutor.shutdown();}
}