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

原创我会带着你远行 2024-10-22 14:00 63阅读 0赞

在Java中，CountDownLatch和Semaphore是两种常用的并发工具。它们主要用于控制多个线程的执行顺序和同时执行的数量。

1. CountDownLatch

CountDownLatch最初用于在一个线程完成工作后，通知所有等待它的其他线程。

使用示例：

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

public class CountDownLatchExample {
    private final CountDownLatch signal = new CountDownLatch(1);

public void doSomething() throws InterruptedException {
        // 模拟一些耗时的操作
        Thread.sleep(2000); // 假设这个操作需要2秒

System.out.println("Finished doing something...");

// 发送信号通知其他线程
        signal.countDown();
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample();

new Thread(() -> example.doSomething())).start();

try {
            // 等待所有任务完成
            example.signal.await();
            System.out.println("All tasks finished.");
        } catch (InterruptedException e) {
            e.printStackTrace();
            System.out.println("Waiting interrupted.");
        }
    }
}
```

2. Semaphore

Semaphore是另一种线程控制工具，它允许你最多获得n个许可（大于等于0），当所有许可都被获取后，后续请求会被阻塞。

使用示例：

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

public class SemaphoreExample {
    private final Semaphore permit = new Semaphore(1);

public void doSomething() throws InterruptedException {
        System.out.println("Trying to get semaphore...");

// 请求许可
        permit.acquire();

System.out.println("Semaphore obtained. Doing something...");

// 模拟一些耗时的操作
        Thread.sleep(2000); // 假设这个操作需要2秒

System.out.println("Finished doing something...");
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();

new Thread(() -> example.doSomething())).start();

try {
            // 等待所有任务完成
            example.permit.release();
            System.out.println("All tasks finished. Semaphore released.");
        } catch (InterruptedException e) {
            e.printStackTrace();
            System.out.println("Waiting interrupted.");
        }
    }
}
```

以上就是CountDownLatch和Semaphore在Java并发中的基本使用示例。