如何实现一个高效的Java线程池并管理任务-蒲公英云

如何实现一个高效的Java线程池并管理任务

在Java中，我们可以使用ExecutorService接口来创建一个线程池。以下是一个简单的步骤和示例：

导入相关包：

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

创建线程池，可以指定线程的数量或者最大线程数，以及任务的提交接口（Runnable或Callable）：
```
ExecutorService executor = Executors.newFixedThreadPool(10); // 创建固定大小的线程池
```
提交任务到线程池，使用submit()方法，可以将Runnable对象或者Callable对象放入队列等待执行：
```java
// 提交一个Runnable任务
Runnable task1 = () -> {
System.out.println(“Task 1 executed.”);
};
executor.submit(task1);

// 提交一个Callable任务，会返回一个结果
Callable task2 = () -> {
System.out.println(“Task 2 executed.”);
return “Task result”;
};
String result = executor.submit(task2).get(); // 获取任务的结果


4. **关闭线程池**，当线程池不再需要时，可以调用`shutdown()`方法来停止接收新的任务，然后调用`shutdownNow()`方法来立即停止所有正在执行的任务：
```java
executor.shutdown();
while (!executor.isTerminated()) {
    // 等待所有任务完成
}