Java并发工具：CountDownLatch与Semaphore的使用实例

原创曾经终败给现在 2024-10-09 19:57 83阅读 0赞

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

1. CountDownLatch：

CountDownLatch是一个单例类，它表示一个等待队列的大小。当一个线程调用`countDown()`方法时，会将该线程加入到等待队列中，并使计数器减一。

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

public class CountDownLatchExample {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(3);

// 创建并启动三个线程，每个线程调用countDown方法
        Thread thread1 = new Thread(() -> countDownLatch.countDown()));
        Thread thread2 = new Thread(() -> countDownLatch.countDown()));
        Thread thread3 = new Thread(() -> countDownLatch.countDown()));

thread1.start();
        thread2.start();
        thread3.start();

// 等待所有计数器归零
        countDownLatch.await();

System.out.println("All threads finished.");
    }
}
```
2. Semaphore：

Semaphore是一种线程同步工具，它允许在固定数量的许可（tokens）存在的情况下进行并发访问。

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

public class SemaphoreExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个semaphore，初始许可值为1
        Semaphore semaphore = new Semaphore(1);

// 定义两个线程，每个线程都需要获取semaphore的许可
        Thread thread1 = new Thread(() -> semaphore.acquire()));
        Thread thread2 = new Thread(() -> semaphore.acquire()));

// 启动这两个线程
        thread1.start();
        thread2.start();

// 等待所有线程完成任务
        thread1.join();
        thread2.join();

System.out.println("All threads finished with semaphore.");
    }
}
```
总结：
CountDownLatch和Semaphore都是Java并发工具箱中的重要组件，它们分别用于控制等待队列的大小以及限制同时访问资源的数量。