Java并发编程：CountDownLatch和Semaphore实战案例

原创超、凢脫俗 2024-10-08 17:21 83阅读 0赞

在Java的并发编程中，`CountDownLatch` 和 `Semaphore` 是两个常用的同步工具。下面我们将通过实例来理解和运用这两种工具。

1. CountDownLatch（倒计时器）

- 原理：当一个CountDownLatch的count下降到0时，所有等待它的线程将被唤醒。

- 实战案例：
```java
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

public class CountDownLatchExample {
    public static void main(String[] args) {
        // 创建一个倒计数器，初始值为5
        CountDownLatch countDown = new CountDownLatch(5);

// 创建线程并添加到线程池中
        Thread thread1 = new Thread(() -> countDown.countDown()));
        Thread thread2 = new Thread(() -> countDown.countDown()));
        Thread thread3 = new Thread(() -> countDown.countDown()));
        Thread thread4 = new Thread(() -> countDown.countDown()));

// 将线程加入到线程池中
        ThreadPoolExecutor executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(5);
        executor.execute(thread1);
        executor.execute(thread2);
        executor.execute(thread3);
        executor.execute(thread4);

// 等待倒计时结束，所有等待它的线程将被唤醒
        try {
            countDown.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```
在这个例子中，我们创建了一个初始值为5的`CountDownLatch`。然后创建了五个线程，每个线程都会尝试减少计数器的计数值。

当所有线程都开始执行时，倒计时开始。当某个线程完成其减计任务后，调用`await()`，等待倒计时结束。所有其他线程也会在倒计时结束后被唤醒。