Java并发工具类：如Semaphore和CyclicBarrier的问题解析

原创浅浅的花香味﹌ 2024-12-13 08:42 11阅读 0赞

在Java编程中，`Semaphore`和`CyclicBarrier`是两个非常重要的并发工具类，它们主要用于控制线程的执行顺序和数量。

1. Semaphore（信号量）：
- 作用：信号量用于控制同时访问特定资源的线程数量。当资源可用时，信号量值加1；反之，信号量值减1。
- 示例代码：
```java
Semaphore semaphore = new Semaphore(2); // 初始化为最多允许两个线程同时访问

// 线程执行逻辑
Thread t1 = new Thread(() -> {
    semaphore.acquire(); // 请求访问资源
    System.out.println("t1 acquired the semaphore");
    semaphore.release(); // 释放对资源的占用
}));
Thread t2 = new Thread(() -> {
    semaphore.acquire(); // 请求访问资源
    System.out.println("t2 acquired the semaphore");
    semaphore.release(); // 释放对资源的占用
}));
t1.start();
t2.start();
```
2. CyclicBarrier（循环屏障）：
- 作用：CyclicBarrier用于控制一组线程同步到达某个共同点。到达这个共同点后，所有线程都会等待该屏障。
- 示例代码：
```java
CyclicBarrier barrier = new CyclicBarrier(3); // 初始化为最多允许三个线程同时到达

// 线程执行逻辑
Thread t1 = new Thread(() -> {
    try {
        barrier.await(); // 请求到达屏障点
        System.out.println("t1 reached the barrier");
    } catch (Exception e) {
        e.printStackTrace();
    }
}));
Thread t2 = new Thread(() -> {
    try {
        barrier.await(); // 请求到达屏障点
        System.out.println("t2 reached the barrier");
    } catch (Exception e) {
        e.printStackTrace();
    }
});
t1.start();
t2.start();
```
总结：
`Semaphore`用于控制线程对特定资源的访问，而`CyclicBarrier`则用于控制一组线程同步到达某个点。