Java并发工具：CountDownLatch和Semaphore的应用案例

原创「爱情、让人受尽委屈。」 2024-09-29 16:00 84阅读 0赞

CountDownLatch和Semaphore是Java中两个非常重要的并发工具，主要用于线程间的同步与协调。下面我们将通过实际案例来展示它们的使用。

1. CountDownLatch（倒计时）

**应用场景：** 当一个任务完成后通知所有等待的任务完成。

```java
import java.util.concurrent.CountDownLatch;

public class CounterExample {
    public static void main(String[] args) {
        // 创建一个CountDownLatch，初始值为3
        CountDownLatch countDownLatch = new CountDownLatch(3);

// 创建三个线程，每个线程执行计数任务
        Thread thread1 = new Thread(() -> countDownLatch.countDown()));
        Thread thread2 = new Thread(() -> countDownLatch.countDown()));
        Thread thread3 = new Thread(() -> countDownLatch.countDown()));

// 启动线程
        thread1.start();
        thread2.start();
        thread3.start();

// 等待所有任务完成，倒计数结束
        try {
            countDownLatch.await();
            System.out.println("All tasks have completed.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

2. Semaphore（信号量）

**应用场景：** 当一个资源（如锁）被多个线程共享时，可以使用Semaphore来控制并发访问的限制。

```java
import java.util.concurrent.Semaphore;

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

// 创建两个线程，每个线程尝试获取资源（如锁）
        Thread thread1 = new Thread(() -> semaphore.acquire()));
        Thread thread2 = new Thread(() -> semaphore.acquire()));

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

// 等待所有任务完成，信号量释放
        try {
            thread1.join();
            thread2.join();
            semaphore.release();  // 信号量释放
            System.out.println("All tasks have completed and resource released.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

总结：CountDownLatch主要用于线程间的倒计时同步，而Semaphore则用于控制对共享资源的并发访问。根据实际需求选择合适的工具进行使用。