如何使用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() 方法来等待其他线程，直到所有线程都到达屏障点后才会继续执行。