如何使用Java Barrier实现线程同步

在Java中，可以使用 CyclicBarrier 类来实现线程同步。CyclicBarrier 是一个同步辅助类，允许一组线程在达到某个屏障点之前互相等待。

下面是一个使用 CyclicBarrier 实现线程同步的示例代码：

import java.util.concurrent.CyclicBarrier;  public class BarrierExample {     public static void main(String[] args) {         // 创建一个 CyclicBarrier，指定需要等待的线程数量为3         CyclicBarrier barrier = new CyclicBarrier(3);          // 创建三个线程         Thread thread1 = new Thread(new Worker(barrier));         Thread thread2 = new Thread(new Worker(barrier));         Thread thread3 = new Thread(new Worker(barrier));          // 启动三个线程         thread1.start();         thread2.start();         thread3.start();     }      static class Worker implements Runnable {         private CyclicBarrier barrier;          public Worker(CyclicBarrier barrier) {             this.barrier = barrier;         }          @Override         public void run() {             try {                 System.out.println(Thread.currentThread().getName() + " 正在执行任务...");                 // 等待所有线程到达屏障点                 barrier.await();                 System.out.println(Thread.currentThread().getName() + " 完成任务");             } catch (Exception e) {                 e.printStackTrace();             }         }     } } 

在上面的示例中，创建了一个 CyclicBarrier 对象并指定需要等待的线程数量为3。然后创建了三个线程，并在每个线程中执行任务。每个线程执行任务时会调用 barrier.await() 方法来等待其他线程，直到所有线程都到达屏障点后才会继续执行。