Java线程池：异步处理任务案例

原创忘是亡心i 2024-11-07 01:24 18阅读 0赞

Java线程池是一种执行器（Executor），用于在一个后台线程中执行任务。线程池的主要目的是减少在创建和销毁线程时所产生的性能开销。通过重用已经创建的线程来执行新的任务，线程池提高了程序的响应速度，并且提供了更好的系统资源管理。

下面是一个使用Java线程池进行异步处理任务的简单案例：

```javaimport java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class ThreadPoolExample {

public static void main(String[] args) {
// 创建一个固定大小的线程池ExecutorService executor = Executors.newFixedThreadPool(4);

// 提交任务到线程池 for (int i =0; i <10; i++) {
int taskId = i;
 executor.submit(() -> {
 System.out.println("执行任务：" + taskId + "线程：" + Thread.currentThread().getName());
//模拟任务执行时间 try {
 TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
 }
 });
 }

// 关闭线程池，不再接受新任务，已提交的任务继续执行 executor.shutdown();

//等待所有任务完成 try {
if (!executor.awaitTermination(60, TimeUnit.SECONDS)) {
// 超时后终止当前正在执行的任务 executor.shutdownNow();
 }
} catch (InterruptedException ex) {
// 如果等待时被中断，重新设置中断状态ex.printStackTrace();
 executor.shutdownNow();
 }
 }
}
```在这个例子中，我们创建了一个固定大小为4的线程池，这意味着最多可以同时执行4个任务。我们提交了10个任务到线程池中，每个任务简单地打印出任务ID和执行任务的线程名称，并模拟了2秒的执行时间。

`executor.shutdown()` 方法用于关闭线程池，不再接受新任务，但已提交的任务会继续执行直到完成。`executor.awaitTermination()` 方法用于等待所有已提交的任务完成，如果在指定的时间内没有完成，则会调用`executor.shutdownNow()`来尝试停止所有正在执行的任务。

这个案例展示了如何使用Java线程池来异步处理多个任务，提高程序的并发性能。