Java中的并发控制工具：CountDownLatch和Semaphore的使用案例

原创傷城~ 2024-10-14 07:27 58阅读 0赞

在Java中，CountDownLatch和Semaphore是两种常用的并发控制工具。它们主要用于协调多个线程的执行。

1. CountDownLatch：

CountDownLatch最初用于一个或多个等待其他任务完成的线程。当最后一个任务完成后（调用countDown方法），所有等待的任务将被唤醒并继续执行。

使用案例：
```java
// 任务A，需要等待任务B完成
class TaskA {
    private final CountDownLatch latch;

TaskA(CountDownLatch latch) {
        this.latch = latch;
    }

void run() throws InterruptedException {
        // 等待任务B完成
        latch.await();
        System.out.println("Task A completed");
    }
}

// 任务B，不需要等待其他任务完成
class TaskB {
    public void run() {
        System.out.println("Task B started");
        // 执行任务逻辑
        // ...
        System.out.println("Task B completed");
    }
}
```
2. Semaphore：

Semaphore是一种更复杂的并发工具，它控制同时访问特定资源的线程数。当可用的资源大于0时，线程可以被许可并执行；反之，则会阻塞等待。

使用案例：
```java
// 任务A，需要1个许可证才能运行
class TaskA {
    private final Semaphore semaphore;

TaskA(Semaphore semaphore) {
        this.semaphore = semaphore;
    }

void run() throws InterruptedException {
        // 获取许可证（如果当前可用资源大于0）
        semaphore.acquire();
        System.out.println("Task A started with license");

// 执行任务逻辑
        // ...

System.out.println("Task A completed with license");
        // 释放许可证，允许其他任务获取
        semaphore.release();
    }
}

// 任务B，不需要许可证即可运行
class TaskB {
    public void run() {
        System.out.println("Task B started without license");

// 执行任务逻辑
        // ...

System.out.println("Task B completed without license");
    }
}
```
总之，CountDownLatch用于线程间等待，Semaphore则更复杂，它控制同时访问资源的线程数。在具体场景中选择合适的工具进行并发控制。