Java并发编程：Semaphore和CyclicBarrier使用问题示例

原创水深无声 2024-10-11 04:57 35阅读 0赞

Semaphore（信号量）和CyclicBarrier（循环屏障）都是Java中用于管理多个线程对共享资源的访问的工具。

1. Semaphore示例：
```java
import java.util.concurrent.Semaphore;

public class SemaphoreExample {
    private Semaphore semaphore = new Semaphore(2); // 初始化为最多两个线程

public void thread1() throws InterruptedException {
        semaphore.acquire(); // 获取信号量，如果信号量小于0，则会抛出异常
        System.out.println("Thread 1 is executing..."); // 执行任务
        semaphore.release(); // 释放信号量，表示当前线程执行完毕
    }

public void thread2() throws InterruptedException {
        semaphore.acquire(); // 获取信号量
        System.out.println("Thread 2 is executing..."); // 执行任务
        semaphore.release(); // 释放信号量，表示当前线程执行完毕
    }

public static void main(String[] args) {
        SemaphoreExample example = new SemaphoreExample();
        Thread thread1 = new Thread(example::thread1);
        Thread thread2 = new Thread(example::thread2);
        thread1.start();
        thread2.start();
    }
}
```
在这个示例中，Semaphore用于限制同时访问资源的线程数量。

2. CyclicBarrier示例：
```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    private final CyclicBarrier barrier = new CyclicBarrier(2, "Cyclic Barrier Example")); // 初始化为最多两个线程

public void thread1() throws Exception {
        barrier.await(); // 等待信号，当线程数达到屏障设定的数量时会释放信号
        System.out.println("Thread 1 is executing..."); // 执行任务
    }

public void thread2() throws Exception {
        barrier.await(); // 等待信号，当线程数达到屏障设定的数量时会释放信号
        System.out.println("Thread 2 is executing..."); // 执行任务
    }

public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample();
        Thread thread1 = new Thread(example::thread1));
        Thread thread2 = new Thread(example::thread2));
        thread1.start();
        thread2.start();
    }
}
```
在这个示例中，CyclicBarrier用于在所有线程完成某项任务后一起行动。