深入理解Java的并发编程工具：ExecutorService和Future接口实例

原创悠悠 2024-11-26 14:09 40阅读 0赞

在Java中，ExecutorService和Future接口是用于并发编程的重要工具。

1. ExecutorService（线程池）：

ExecutorService是一个接口，它代表一组等待执行的任务。Java提供了一些实现这个接口的具体类，如FixedThreadPool和Executors等。

使用例子：
```java
// 创建一个固定大小的线程池
int threadCount = 5;
ExecutorService executor = Executors.newFixedThreadPool(threadCount);

// 提交任务到线程池
Runnable task1 = () -> {
    System.out.println("Task 1 executing...");
    // 这里进行你的任务逻辑
};
executor.submit(task1);

// 关闭线程池，释放资源
executor.shutdown();
while (!executor.isTerminated()) {
    // 等待所有任务完成或者关闭线程池
}
executor.clearTasks();

// 如需获取任务的执行结果，可以使用Future接口
Future<String> futureTask = executor.submit(() -> "Task result"));
try {
    String result = futureTask.get();
    System.out.println("Task 1 result: " + result);
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
}
```

2. Future接口：

Future是Java并发API中一个非常重要的接口，它代表了一个异步任务的结果。

当一个任务被提交到ExecutorService后，我们通常会通过Future来获取这个任务的执行结果。

使用例子：
```java
// 提交任务并获取Future
Runnable task = () -> {
    // 这里进行你的任务逻辑
    System.out.println("Task executing...");
    try {
        Thread.sleep(2000); // 模拟耗时操作
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
};
Future<Void> future = executor.submit(task);

// 等待任务完成
try {
    future.get(); // 获取null表示任务已完成
} catch (InterruptedException | ExecutionException e) {
    System.out.println("Error occurred while waiting for task to complete.");
    e.printStackTrace();
}

// 如果需要清理资源，可以调用clearTasks()方法
executor.clearTasks();
```

总结来说，ExecutorService提供线程管理服务，而Future接口则用于获取异步任务的结果。在并发编程中，它们是相互配合的重要工具。