Java并发编程中，CountDownLatch和Semaphore的应用示例

原创朱雀 2024-10-16 01:57 43阅读 0赞

CountDownLatch和Semaphore都是Java并发工具包（java.util.concurrent）中的类，用于管理多个线程的交互。

1. CountDownLatch:
- 应用场景：当一个或多个任务完成后，会通知其他等待的任务。
- 示例代码：
```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private final CountDownLatch countDownLatch = new CountDownLatch(3);

public void task(int index) {
        try {
            System.out.println("Task " + index + " started");
            countDownLatch.await(index, TimeUnit.SECONDS);
            System.out.println("Task " + index + " finished");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample();
        new Thread(() -> example.task(0)), "Task 0").start();
        new Thread(() -> example.task(1)), "Task 1").start();
        new Thread(() -> example.task(2)), "Task 2").start();
    }
}
```
在这个示例中，三个任务分别执行，当一个任务完成时，会调用`countDownLatch.await()`等待计数器减一。这样其他线程就会知道这个任务已经完成了。

2. Semaphore：
- 应用场景：控制对共享资源的访问，如信号量、生产者消费者等。
- 示例代码：
```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private final Semaphore semaphore = new Semaphore(3);

public void task() {
        try {
            System.out.println("Task started");
            semaphore.acquire();
            System.out.println("Task finished");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        new Thread(() -> example.task()), "Task").start();
    }
}
```
在这个示例中，一个任务尝试获取`semaphore`的三个许可。如果当前没有许可可用（即`semaphore.available()`返回0），那么线程将被阻塞，直到有许可可用。

以上两个例子展示了CountDownLatch和Semaphore在多线程环境中的基本使用。