cyclicbarrier在Java中如何使用

CyclicBarrier是一个同步辅助类，它允许一组线程在达到某个屏障点之前彼此互相等待。在Java中，可以通过以下步骤来使用CyclicBarrier：

1. 创建CyclicBarrier对象并指定参与线程的数量和到达屏障点时需要执行的动作。

CyclicBarrier barrier = new CyclicBarrier(3, () -> {     System.out.println("All threads have reached the barrier"); }); 

2. 创建并启动线程，每个线程在到达屏障点之前调用CyclicBarrier的await()方法。

Thread t1 = new Thread(() -> {     try {         System.out.println("Thread 1 is waiting at the barrier");         barrier.await();         System.out.println("Thread 1 has passed the barrier");     } catch (InterruptedException | BrokenBarrierException e) {         e.printStackTrace();     } }); t1.start(); 

3. 当指定数量的线程都调用了await()方法后，CyclicBarrier会执行指定的动作，并重置屏障点，使得线程可以再次在屏障点等待。

Thread t2 = new Thread(() -> {     try {         System.out.println("Thread 2 is waiting at the barrier");         barrier.await();         System.out.println("Thread 2 has passed the barrier");     } catch (InterruptedException | BrokenBarrierException e) {         e.printStackTrace();     } }); t2.start(); 

通过以上步骤，可以实现多个线程在达到某个屏障点后进行同步操作。需要注意的是，CyclicBarrier只能被重置一次，之后需要重新创建新的CyclicBarrier对象。