package com.basic;

import java.util.concurrent.*;

/**
 * @program JavaBooks
 * @description: CyclicBarrier的使用示例
 * @author: mf
 * @create: 2020/01/09 17:17
 */

public class T34 {

    // 请求的数量
    private static final int threadCount = 30;

    // 需要同步的线程数量
    private static final CyclicBarrier cyclicBarrier = new CyclicBarrier(5);

    public static void main(String[] args) throws InterruptedException {
        ExecutorService service = Executors.newFixedThreadPool(10);

        for (int i = 0; i < threadCount; i++) {
            final int threadNum = i;
            Thread.sleep(1000);
            service.execute(() -> {
                test(threadNum);
            });
        }
        service.shutdown();
    }

    private static void test(int threadNum) {
        System.out.println("threadNum: " + threadNum + " is ready");
        try {
            cyclicBarrier.await(60, TimeUnit.SECONDS); // 等待60s，保证子线程完全执行结束
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (BrokenBarrierException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            e.printStackTrace();
        }
        System.out.println("threadNum: " + threadNum + " finish...");
    }
}