Java并发工具：Semaphore与CyclicBarrier问题示例

原创妖狐艹你老母 2024-11-28 12:36 31阅读 0赞

Semaphore和CyclicBarrier是Java中常用的两种并发工具，它们主要用来控制线程的并发执行。

1. Semaphore（信号量）：
Semaphore是一种资源管理工具，它维护一个固定大小的计数器。当一个线程请求使用某个资源时，会尝试将信号量的值减1。如果成功，则可以使用这个资源。反之，如果减1失败，说明当前资源已被其他线程占用，该线程需要等待。

2. CyclicBarrier（循环屏障）：
CyclicBarrier是一种同步工具，它允许一个或多个屏障等待一组线程到达后一起行动。换句话说，当所有线程成功通过屏障时，会触发一个特定的回调动作。

示例代码：

Semaphore example1 = new Semaphore(3);
// 多个线程尝试获取资源
Thread t1 = new Thread(() -> {
    try {
        t1.acquire();
        System.out.println("Thread 1 acquired the resource");
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}));
Thread t2 = new Thread(() -> {
    try {
        t2.acquire();
        System.out.println("Thread 2 acquired the resource");
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}});
t1.start(); t2.start();

CyclicBarrier example2 = new CyclicBarrier(3, () -> {
    System.out.println("All threads reached barrier and executed callback");
}));
// 多个线程尝试到达屏障
Thread t3 = new Thread(() -> {
    try {
        t3.join();
        example2.signal();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}));
t3.start();

在上述示例中，Semaphore用于控制资源的并发获取，而CyclicBarrier则用于协调多个线程一起完成某个任务。