深入理解Java的并发工具类：Semaphore、CyclicBarrier等案例

原创女爷i 2024-11-21 17:24 22阅读 0赞

在Java中，`Semaphore`和`CyclicBarrier`都是用于管理线程并发的工具类。

1. Semaphore（信号量）：
Semaphore是一种信号量机制，它用于控制在同一时间内访问特定资源的线程数。它的操作主要包括初始化、增加计数、减少计数和检查状态等。

案例：

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

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

public void threadA() throws InterruptedException {
        System.out.println("Thread A: Entering the semaphore.");
        semaphore.acquire();
        System.out.println("Thread A: Acquired the semaphore and exiting.");
    }

public void threadB() throws InterruptedException {
        System.out.println("Thread B: Entering the semaphore.");
        semaphore.acquire();
        System.out.println("Thread B: Acquired the semaphore but decided to wait.");
        // simulate a long operation
        Thread.sleep(500);
        System.out.println("Thread B: Exiting after waiting.");
        semaphore.release();
    }

public void runExample() throws InterruptedException {
        new Thread(threadA)).start();
        new Thread(threadB)).start();
    }

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

2. CyclicBarrier（循环屏障）：
CyclicBarrier用于控制一组线程以相同的时间点进行操作。当第一个线程调用`await()`方法时，所有等待的线程都会被唤醒。

案例：

```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    private CyclicBarrier barrier = new CyclicBarrier(2, "Signal"));

public void threadA() throws InterruptedException {
        System.out.println("Thread A: Entering the cyclic barrier.");
        barrier.await(); // Wait for signal to proceed
        System.out.println("Thread A: Exiting after reaching the cyclic barrier.");
    }

public void threadB() throws InterruptedException {
        System.out.println("Thread B: Entering the cyclic barrier.");
        barrier.await(); // Wait for signal to proceed
        System.out.println("Thread B: Exiting after reaching the cyclic barrier.");
    }

public void runExample() throws InterruptedException {
        new Thread(threadA)).start();
        new Thread(threadB)).start();
    }

public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample();
        example.runExample();
    }
}
```

在以上示例中，`Semaphore`用来控制进入某个资源的线程数，而`CyclicBarrier`则用于同步一组线程，所有线程会等待到达这个屏障点后继续执行。