Java并发工具：CountDownLatch和Semaphore的实战案例

原创叁歲伎倆 2024-11-15 07:57 25阅读 0赞

在Java并发编程中，CountDownLatch和Semaphore是两种常用的同步工具。它们各自有不同的应用场景。

1. CountDownLatch：

CountDownLatch最初用于一个线程等待其他线程完成某些操作。它的主要方法是`await()`，当调用这个方法时，当前线程会阻塞，直到COUNTDOWN为0，或者接收到`signal(int count)}`的消息。

实战案例：
```java
// 初始化计数器
CountDownLatch latch = new CountDownLatch(2);

// 创建两个线程
new Thread(() -> {
    try {
        // 让第一个线程等待
        latch.await();
        
        System.out.println("Thread 1 finished");
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

new Thread(() -> {
    try {
        // 让第二个线程立即执行并完成任务，然后唤醒等待的线程
        latch.countDown();
        latch.await();
        
        System.out.println("Thread 2 finished");
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();
```

2. Semaphore：

Semaphore是一种信号量，它用来控制同时访问特定资源的线程数量。Semaphore的主要方法是`acquire(int n)`和`release()`。

实战案例：
```java
// 初始化一个资源为1的信号量
Semaphore semaphore = new Semaphore(1);

// 创建一个线程
new Thread(() -> {
    try {
        // 请求使用资源，如果当前资源不足，则阻塞
        semaphore.acquire();

System.out.println("Thread 2 acquired resource");

// 使用完资源后，释放给其他请求者
        semaphore.release();

System.out.println("Thread 2 released resource");
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();
```

以上两个工具在Java并发编程中都有广泛的应用。根据实际需求，选择合适的方法进行同步和协调。