如何使用Java Barrier實(shí)現(xiàn)線程同步

在Java中，可以使用 CyclicBarrier 類來實(shí)現(xiàn)線程同步。CyclicBarrier 是一個(gè)同步輔助類，允許一組線程在達(dá)到某個(gè)屏障點(diǎn)之前互相等待。

下面是一個(gè)使用 CyclicBarrier 實(shí)現(xiàn)線程同步的示例代碼：

import java.util.concurrent.CyclicBarrier;

public class BarrierExample {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè) CyclicBarrier，指定需要等待的線程數(shù)量為3
        CyclicBarrier barrier = new CyclicBarrier(3);

        // 創(chuàng)建三個(gè)線程
        Thread thread1 = new Thread(new Worker(barrier));
        Thread thread2 = new Thread(new Worker(barrier));
        Thread thread3 = new Thread(new Worker(barrier));

        // 啟動(dòng)三個(gè)線程
        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() + " 正在執(zhí)行任務(wù)...");
                // 等待所有線程到達(dá)屏障點(diǎn)
                barrier.await();
                System.out.println(Thread.currentThread().getName() + " 完成任務(wù)");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

在上面的示例中，創(chuàng)建了一個(gè) CyclicBarrier 對象并指定需要等待的線程數(shù)量為3。然后創(chuàng)建了三個(gè)線程，并在每個(gè)線程中執(zhí)行任務(wù)。每個(gè)線程執(zhí)行任務(wù)時(shí)會(huì)調(diào)用 barrier.await() 方法來等待其他線程，直到所有線程都到達(dá)屏障點(diǎn)后才會(huì)繼續(xù)執(zhí)行。