【Java并发编程】CyclicBarrier的6大典型应用场景:让多线程协作更高效

• 【Java并发编程】CyclicBarrier的6大典型应用场景:让多线程协作更高效

public class AverageCalculator {
    public static void main(String[] args) {
        int threadCount = 10;
        int dataBlockSize = 1000;
        CyclicBarrier barrier = new CyclicBarrier(threadCount + 1, () -> {
            // 汇总结果的逻辑
            double totalAverage = calculateTotalAverage(threadCount, dataBlockSize);
            System.out.println("Total average: " + totalAverage);
        });

        // 创建并启动计算线程
        for (int i = 0; i < threadCount; i++) {
            new CalculationThread(i, dataBlockSize, barrier).start();
        }

        try {
            // 等待所有线程完成计算
            barrier.await();
        } catch (InterruptedException | BrokenBarrierException e) {
            e.printStackTrace();
        }
    }

    // 省略具体的计算逻辑
    private static double calculateTotalAverage(int threadCount, int dataBlockSize) {
        // ...
        return totalAverage;
    }

    private static class CalculationThread extends Thread {
        private final int id;
        private final int dataBlockSize;
        private final CyclicBarrier barrier;

        public CalculationThread(int id, int dataBlockSize, CyclicBarrier barrier) {
            this.id = id;
            this.dataBlockSize = dataBlockSize;
            this.barrier = barrier;
        }

        @Override
        public void run() {
            // 计算本线程的数据块平均值
            double average = calculateAverage(dataBlockSize);
            System.out.println("Thread " + id + " calculated average: " + average);

            try {
                // 等待其他线程完成计算
                barrier.await();
            } catch (InterruptedException | BrokenBarrierException e) {
                e.printStackTrace();
            }
        }

        // 省略具体的计算逻辑
        private double calculateAverage(int dataBlockSize) {
            // ...
            return average;
        }
    }
}