Java ~ Executor ~ ExecutorCompletionService【总结】

**Java Executor 和 ExecutorCompletionService**

在 Java 中，Executor 是一个用于执行任务的接口，它提供了一个高层次的抽象，使得我们可以轻松地管理线程池。ExecutorCompletionService 是 Executor 的一个子类，它为我们提供了一种更方便的方式来获取任务的结果。

**什么是 Executor**

Executor 是 Java 中的一个重要接口，它定义了一个执行任务的方法。Executor 提供了一个高层次的抽象，使得我们可以轻松地管理线程池。Executor 的主要功能是：

* 执行任务：Executor 提供了一个 execute() 方法，用于执行任务。
* 管理线程池：Executor 可以管理线程池，包括创建、销毁和调度线程。

**什么是 ExecutorCompletionService**

ExecutorCompletionService 是 Executor 的一个子类，它为我们提供了一种更方便的方式来获取任务的结果。ExecutorCompletionService 的主要功能是：

* 获取任务结果：ExecutorCompletionService 提供了一个 take() 方法，用于获取任务的结果。
* 等待任务完成：ExecutorCompletionService 可以等待任务完成，并返回任务的结果。

**使用 Executor 和 ExecutorCompletionService**

下面是一个示例代码片段，演示了如何使用 Executor 和 ExecutorCompletionService：

javaimport java.util.concurrent.Executor;
import java.util.concurrent.ExecutorCompletionService;
import java.util.concurrent.Executors;

public class Main {
 public static void main(String[] args) throws InterruptedException {
 // 创建一个线程池 Executor executor = Executors.newFixedThreadPool(5);

 // 创建一个ExecutorCompletionService实例 ExecutorCompletionService completionService = new ExecutorCompletionService<>(executor);

 // 提交任务 completionService.submit(() -> {
 System.out.println("Task1 started");
 Thread.sleep(1000);
 return "Task1 completed";
 });

 completionService.submit(() -> {
 System.out.println("Task2 started");
 Thread.sleep(2000);
 return "Task2 completed";
 });

 // 等待任务完成并获取结果 String result = completionService.take().get();
 System.out.println(result);

 // 关闭线程池 executor.shutdown();
 }
}