import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierExample {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè)新的CyclicBarrier，其中包括4個(gè)線(xiàn)程
        CyclicBarrier barrier = new CyclicBarrier(4, () -> System.out.println("所有線(xiàn)程到達(dá)屏障點(diǎn)，可以繼續(xù)執(zhí)行！"));
        // 創(chuàng)建四個(gè)線(xiàn)程
        for (int i = 0; i < 4; i++) {
            int threadNum = i;
            new Thread(() -> {
                try {
                    System.out.println("線(xiàn)程 " + threadNum + " 正在執(zhí)行任務(wù)");
                    Thread.sleep(1000); // 模擬任務(wù)執(zhí)行時(shí)間
                    System.out.println("線(xiàn)程 " + threadNum + " 到達(dá)屏障點(diǎn)");
                    barrier.await(); // 等待其他線(xiàn)程
                    System.out.println("線(xiàn)程 " + threadNum + " 繼續(xù)執(zhí)行其他任務(wù)");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierReuseExample {
    private static final int THREAD_COUNT = 3;
    public static void main(String[] args) {
        CyclicBarrier barrier = new CyclicBarrier(THREAD_COUNT, () -> System.out.println("所有線(xiàn)程完成當(dāng)前階段，準(zhǔn)備進(jìn)入下一階段！"));
        for (int i = 0; i < THREAD_COUNT; i++) {
            int threadNum = i;
            new Thread(() -> {
                try {
                    for (int phase = 1; phase <= 3; phase++) { // 假設(shè)有三個(gè)階段
                        System.out.println("線(xiàn)程 " + threadNum + " 完成階段 " + phase);
                        barrier.await(); // 等待其他線(xiàn)程
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierActionExample {
    public static void main(String[] args) {
        CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("全部線(xiàn)程已到達(dá)屏障點(diǎn)，執(zhí)行屏障動(dòng)作"));
        for (int i = 0; i < 3; i++) {
            new Thread(() -> {
                try {
                    System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行任務(wù)");
                    Thread.sleep(2000); // 模擬任務(wù)執(zhí)行時(shí)間
                    barrier.await(); // 等待其他線(xiàn)程
                    System.out.println(Thread.currentThread().getName() + " 繼續(xù)執(zhí)行后續(xù)任務(wù)");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

import java.util.concurrent.CyclicBarrier;
public class ParallelComputationExample {
    private static final int THREAD_COUNT = 4;
    public static void main(String[] args) {
        CyclicBarrier barrier = new CyclicBarrier(THREAD_COUNT, () -> System.out.println("所有子任務(wù)處理完成，準(zhǔn)備進(jìn)入下一步！"));
        for (int i = 0; i < THREAD_COUNT; i++) {
            new Thread(new Worker(i, barrier)).start();
        }
    }
    static class Worker implements Runnable {
        private final int threadNumber;
        private final CyclicBarrier barrier;
        Worker(int threadNumber, CyclicBarrier barrier) {
            this.threadNumber = threadNumber;
            this.barrier = barrier;
        }
        @Override
        public void run() {
            try {
                System.out.println("線(xiàn)程 " + threadNumber + " 正在處理任務(wù)");
                Thread.sleep(2000); // 模擬任務(wù)處理時(shí)間
                System.out.println("線(xiàn)程 " + threadNumber + " 完成任務(wù)，等待其他線(xiàn)程");
                barrier.await(); // 等待其他線(xiàn)程完成
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierApiExample {
    public static void main(String[] args) {
        // 定義一個(gè)新的CyclicBarrier，需要3個(gè)線(xiàn)程協(xié)作
        CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("所有線(xiàn)程準(zhǔn)備就緒，開(kāi)始下一步操作"));

        for (int i = 0; i < 3; i++) {
            new Thread(new Task(barrier), "線(xiàn)程 " + i).start();
        }
    }

    static class Task implements Runnable {
        private final CyclicBarrier barrier;

        Task(CyclicBarrier barrier) {
            this.barrier = barrier;
        }

        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行任務(wù)");
                Thread.sleep(1000); // 模擬任務(wù)執(zhí)行時(shí)間
                System.out.println(Thread.currentThread().getName() + " 完成任務(wù)，等待其他線(xiàn)程");
                barrier.await(); // 等待其他線(xiàn)程
                System.out.println(Thread.currentThread().getName() + " 開(kāi)始執(zhí)行后續(xù)操作");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

import java.util.concurrent.CyclicBarrier;
public class DynamicCyclicBarrierExample {
    public static void main(String[] args) {
        // 初始時(shí)，屏障點(diǎn)設(shè)置為3
        CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("屏障點(diǎn)動(dòng)作執(zhí)行"));
        for (int i = 0; i < 2; i++) { // 初始只啟動(dòng)兩個(gè)線(xiàn)程
            new Thread(new Worker(barrier), "線(xiàn)程 " + i).start();
        }
        // 動(dòng)態(tài)調(diào)整屏障點(diǎn)，現(xiàn)在需要4個(gè)線(xiàn)程到達(dá)屏障點(diǎn)
        barrier.reset(); // 重置CyclicBarrier，這也會(huì)打破任何當(dāng)前等待的線(xiàn)程
        barrier = new CyclicBarrier(4, () -> System.out.println("新的屏障點(diǎn)動(dòng)作執(zhí)行"));
        for (int i = 0; i < 4; i++) { // 現(xiàn)在啟動(dòng)四個(gè)線(xiàn)程
            new Thread(new Worker(barrier), "線(xiàn)程 " + i).start();
        }
    }
    static class Worker implements Runnable {
        private final CyclicBarrier barrier;
        Worker(CyclicBarrier barrier) {
            this.barrier = barrier;
        }
        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " 到達(dá)屏障點(diǎn)");
                barrier.await();
                System.out.println(Thread.currentThread().getName() + " 繼續(xù)執(zhí)行");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class CyclicBarrierWithExecutorServiceExample {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(4);
        CyclicBarrier barrier = new CyclicBarrier(4, () -> System.out.println("所有任務(wù)完成，準(zhǔn)備下一輪執(zhí)行"));
        for (int i = 0; i < 4; i++) {
            executorService.execute(new Worker(barrier));
        }
        executorService.shutdown();
    }
    static class Worker implements Runnable {
        private final CyclicBarrier barrier;
        Worker(CyclicBarrier barrier) {
            this.barrier = barrier;
        }
        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行任務(wù)");
                Thread.sleep(1000);
                barrier.await();
                System.out.println(Thread.currentThread().getName() + " 任務(wù)完成");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
public class CyclicBarrierExceptionHandlingExample {
    public static void main(String[] args) {
        CyclicBarrier barrier = new CyclicBarrier(3);
        for (int i = 0; i < 3; i++) {
            new Thread(new Task(barrier), "線(xiàn)程 " + i).start();
        }
    }
    static class Task implements Runnable {
        private final CyclicBarrier barrier;
        Task(CyclicBarrier barrier) {
            this.barrier = barrier;
        }
        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " 正在執(zhí)行任務(wù)");
                Thread.sleep(1000);
                System.out.println(Thread.currentThread().getName() + " 到達(dá)屏障點(diǎn)，等待其他線(xiàn)程");
                barrier.await(2, TimeUnit.SECONDS); // 設(shè)置超時(shí)時(shí)間為2秒
            } catch (InterruptedException e) {
                System.out.println(Thread.currentThread().getName() + " 被中斷");
            } catch (BrokenBarrierException e) {
                System.out.println(Thread.currentThread().getName() + " 檢測(cè)到屏障損壞");
            } catch (TimeoutException e) {
                System.out.println(Thread.currentThread().getName() + " 等待超時(shí)");
            }
            System.out.println(Thread.currentThread().getName() + " 繼續(xù)執(zhí)行后續(xù)操作");
        }
    }
}