Java并发编程：Semaphore和CountDownLatch实战应用

原创刺骨的言语ヽ痛彻心扉 2024-11-23 20:39 6阅读 0赞

在Java并发编程中，Semaphore（信号量）和CountDownLatch（计数器倒置）是两种重要的同步工具。下面我们将通过实际案例来理解它们的应用。

1. Semaphore（信号量）

信号量用于控制多个临界区的访问。一个信号量由两个基本操作定义：P（wait，减一）和V（signal，增一）。

实战应用：
```java
Semaphore semaphore = new Semaphore(2); // 信号量初始值为2

// 对多个临界资源进行控制
new Thread(() -> {
    try {
        semaphore.acquire(); // 请求访问信号量
        // 进行临界区操作
        System.out.println("Thread 1 entered critical area");
        semaphore.release(); // 释放对信号量的占用
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}) /* 创建并启动新线程 */
.start();
```
2. CountDownLatch（计数器倒置）

CountDownLatch用于协调多个线程。当一个或多个任务完成后，它们会调用`countDown()`方法来减少对应的计数值。

实战应用：
```java
// 初始化一个计数器为10
CountDownLatch countDownLatch = new CountDownLatch(10);

new Thread(() -> {
    for (int i = 0; i < 10; i++) {
        System.out.println("Thread 2 is working on task " + i);
        try {
            // 每完成一个任务，调用countDown方法减少计数
            countDownLatch.countDown();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}) /* 创建并启动新线程 */
.start();

// 等待所有任务完成后，释放CountDownLatch的等待状态
countDownLatch.await();

System.out.println("All tasks completed successfully!");
```
总结：Semaphore和CountDownLatch是Java并发编程中两种常用的同步工具。理解它们的工作原理与使用场景，有助于提高你的Java并发编程能力。