Java中的并发控制工具(如CyclicBarrier)使用示例

原创蔚落 2024-10-14 07:15 55阅读 0赞

在Java中，`CyclicBarrier`是一种同步工具，当屏障被所有到达的线程打破后，它会再次打开，允许新的线程进入。

以下是一个简单的使用示例：

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

public class CyclicBarrierExample {
    public static void main(String[] args) {
        // 创建屏障，初始状态是打开的
        CyclicBarrier barrier = new CyclicBarrier(2, new BarrierTask()));

// 创建两个线程，一个等待屏障，另一个打破屏障
        Thread thread1 = new Thread(new WaiterTask(barrier)));
        Thread thread2 = new Thread(new BreakerTask(barrier)));

// 启动线程
        thread1.start();
        thread2.start();

// 等待所有任务完成
        thread1.join();
        thread2.join();
    }
}

// 等待任务的类
class WaiterTask implements Runnable {
    private CyclicBarrier barrier;

public WaiterTask(CyclicBarrier barrier) {
        this.barrier = barrier;
    }

@Override
    public void run() {
        try {
            // 等待屏障打开
            barrier.await();

// 当屏障打开后，任务完成
            System.out.println("Waiter task completed!");

} catch (Exception e) {
            e.printStackTrace();
        }
    }
}

// 打破屏障的任务类
class BreakerTask implements Runnable {
    private CyclicBarrier barrier;

public BreakerTask(CyclicBarrier barrier) {
        this.barrier = barrier;
    }

@Override
    public void run() {
        try {
            // 等待屏障打开，这个时间可以设置为1秒
            barrier.await(1000);

// 当屏障打开后，任务完成并打破屏障
            System.out.println("Breaker task completed, breaking barrier...");

barrier.open();  // 打破屏障

} catch (Exception e) {
            e.printStackTrace();
        }
    }
}

// 一个简单的屏障任务类
class BarrierTask implements Runnable {
    @Override
    public void run() {
        try {
            // 简单的屏障任务，当屏障被所有线程打破后，打印一条消息
            CyclicBarrier barrier = new CyclicBarrier(2, "Barrier task completed!"));
            Thread.sleep(1000);  // 模拟线程等待的时间

// 当屏障被线程打破后，任务完成
            System.out.println("Barrier task completed!");

} catch (Exception e) {
            e.printStackTrace();
        }
    }
}
```

在这个示例中，我们创建了两个线程（一个WaiterTask和一个BreakerTask），一个CyclicBarrier作为屏障。当所有线程都等待屏障打开后，屏障会被打破，完成任务。