Java并发工具类：如ThreadPoolExecutor、CountDownLatch等详解

原创 ╰半橙微兮° 2024-09-15 16:06 62阅读 0赞

在Java编程中，`java.util.concurrent`包提供了一系列强大的并发工具。这里我们将重点介绍`ThreadPoolExecutor`和`CountDownLatch`。

1. ThreadPoolExecutor
ThreadPoolExecutor是线程池的实现，用于管理一组线程来处理并发任务。主要参数如下：

- corePoolSize：核心线程数，不为0的线程在空闲时会被关闭。
- maximumPoolSize：最大线程数，在核心线程无法满足请求时会起作用。
- keepAliveTime：非活动线程存活时间，表示当线程处于等待任务状态时，允许其生存的最大时间（以毫秒为单位）。

示例代码：

```java
// 创建一个线程池，初始核心线程2个
ExecutorService executor = Executors.newFixedThreadPool(2);

// 提交任务到线程池
for (int i = 0; i < 10; i++) {
    executor.submit(() -> System.out.println("Task " + i)));
}

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

2. CountDownLatch
CountDownLatch是一个同步工具类，它用于协调多个线程的执行。当一个线程调用`countDown()`方法时，该计数器会减1；如果该计数器值变为0，则其他等待该事件的所有线程会被唤醒。

示例代码：

```java
// 创建一个 CountDownLatch, 初始化为 3
CountDownLatch countDownLatch = new CountDownLatch(3);

// 创建多个线程，每个线程调用 countDown 方法
new Thread(() -> countDownLatch.countDown())).start();
new Thread(() -> countDownLatch.countDown())).start();
new Thread(() -> countDownLatch.countDown())).start();

// 等待所有计数器归零
try {
    countDownLatch.await();
} catch (InterruptedException e) {
    // 处理中断异常
    e.printStackTrace();
}
```

总结，`ThreadPoolExecutor`用于管理线程池执行任务，而`CountDownLatch`则是一个协调多个线程的工具。

Java并发工具类：如ThreadPoolExecutor、CountDownLatch等详解

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 Java并发工具类（如Semaphore、CyclicBarrier等）使用的常见误区

相关详解Java中的并发工具类如ConcurrentHashMap

相关 Java并发工具类（如ConcurrentHashMap等）使用案例和理解

相关深入理解Java中的并发工具类：如Lock，Semaphore等

相关 Java并发工具类如CountDownLatch的理解

相关理解Java中并发工具类如CountDownLatch、CyclicBarrier等使用场景

相关理解Java并发工具类：如CountDownLatch、Semaphore等

相关理解Java并发工具类如ForkJoinPool

相关 Java并发工具类如ForkJoinPool详解

相关 Java并发工具类：如ThreadPoolExecutor、CountDownLatch等详解