Java并发工具类使用案例：CountDownLatch和Semaphore

原创今天药忘吃喽~ 2024-11-30 12:57 17阅读 0赞

在Java的并发编程中，CountDownLatch和Semaphore是两种常用的同步工具。

1. CountDownLatch

CountDownLatch是一种倒计数类型的信号量。当一个线程创建了一个CountDownLatch实例，并设置其初始值（如10），那么其他线程等待该CountDownLatch的countdown到零。

使用案例：
```java
import java.util.concurrent.CountDownLatch;

public class CountdownExample {
    private CountDownLatch countDownLatch;
    
    public CountdownExample(int count) {
        this.countDownLatch = new CountDownLatch(count);
    }
    
    public void await() throws InterruptedException {
        countDownLatch.await();
        System.out.println("Countdown reached, signal sent.");
    }
    
    public static void main(String[] args) {
        CountdownExample counter = new CountdownExample(5);
        
        new Thread(() -> {
            try {
                counter.await();
                System.out.println("Thread 1 received signal after countdown.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();

// Simulate another thread sending the signal
        // This can be done outside of the main method, for example in a separate thread.
        new Thread(() -> {
            try {
                counter.countDownLatch.countDown();
                System.out.println("Thread 2 sent signal to countdown.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
    }
}
```

在这个例子中，我们创建了一个CountDownLatch实例，并设置其初始值为5。然后有两个线程分别模拟等待和发送信号的过程。

当信号被发送时，CountDownLatch会减少它的计数，其他线程等待的条件就会得到满足。

2. Semaphore

Semaphore是一种更复杂但用途更广泛的同步工具。它维护一个固定大小的许可池，并允许你获取(增加许可)或释放(减少许可)许可证。

使用案例：
```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore semaphore;

public SemaphoreExample(int permits) {
        this.semaphore = new Semaphore(permits);
    }

// 获取许可证，如果许可池为空则阻塞
    public void acquire() throws InterruptedException {
        semaphore.acquire();
    }

// 释放许可证，减少许可池的大小，如果许可池为0且有线程正在等待，则该线程将被唤醒并继续尝试获取许可证
    public void release() {
        semaphore.release();
    }
}
```

在这个例子中，我们创建了一个Semaphore实例，并设置了初始许可数量。然后我们可以获取许可证（acquire方法）或释放许可证（release方法）。如果当前许可池为空，那么尝试获取许可证的线程会被阻塞。