如何使用Java ExecutorService进行异步编程

Java ExecutorService 是一个用于管理线程池和执行异步任务的接口。它提供了一种将任务提交给线程池执行的方式，从而简化了异步编程。以下是如何使用 ExecutorService 进行异步编程的步骤：

1. 导入所需的包：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

2. 创建一个 ExecutorService 实例：

ExecutorService executorService = Executors.newFixedThreadPool(5); // 创建一个固定大小的线程池

这里我们创建了一个固定大小为5的线程池，你可以根据需要选择其他类型的线程池，例如 newCachedThreadPool() 或 newSingleThreadExecutor()。

3. 定义一个 Runnable 或 Callable 任务：

class MyTask implements Runnable {
    private int id;

    public MyTask(int id) {
        this.id = id;
    }

    @Override
    public void run() {
        System.out.println("Task " + id + " is running on thread " + Thread.currentThread().getName());
        try {
            Thread.sleep(1000); // 模拟耗时操作
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Task " + id + " is completed");
    }
}

或者使用 Callable：

class MyCallable implements Callable<Integer> {
    private int id;

    public MyCallable(int id) {
        this.id = id;
    }

    @Override
    public Integer call() {
        System.out.println("Task " + id + " is running on thread " + Thread.currentThread().getName());
        try {
            Thread.sleep(1000); // 模拟耗时操作
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Task " + id + " is completed");
        return id * 2;
    }
}

4. 将任务提交给 ExecutorService：

Future<?> future = executorService.submit(new MyTask(1)); // 使用 Runnable
// 或
Future<Integer> future = executorService.submit(new MyCallable(1)); // 使用 Callable

5. 获取任务的执行结果（仅适用于 Callable）：

try {
    Integer result = future.get(); // 获取任务的执行结果
    System.out.println("Task result: " + result);
} catch (Exception e) {
    e.printStackTrace();
}

6. 关闭 ExecutorService：

executorService.shutdown(); // 关闭 ExecutorService，不再接受新的任务

注意：在关闭 ExecutorService 之后，已经提交的任务将继续执行，但不会再接受新的任务。如果你需要在关闭 ExecutorService 之前等待所有任务完成，可以使用 executorService.awaitTermination(long timeout, TimeUnit unit) 方法。

这就是如何使用 Java ExecutorService 进行异步编程的基本步骤。你可以根据需要调整线程池大小、任务类型等参数。