import java.util.concurrent.BrokenBarrierException;

import java.util.concurrent.CyclicBarrier;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

/**

 * @author ：jiaolian

 * @date ：Created in 2021-03-01 14:56

 * @description：回环屏障测试--接力赛

 * @modified By：

 * 公众号:叫练

 */

public class CyclicBarrierTest {

    private static final int THREAD_COUNT = 2;

    private static CyclicBarrier cyclicBarrier = new CyclicBarrier(2,()->{

        System.out.println(Thread.currentThread().getName()+"冲破屏障");

    });

    private static ExecutorService executorService = Executors.newFixedThreadPool(THREAD_COUNT);

    public static void main(String[] args) {

        Runnable myTask = new MyTask();

        //初始化两个运动员

        for (int i=0 ;i<THREAD_COUNT; i++) {

            executorService.submit(myTask);

        }

    }

    private static class MyTask implements Runnable {

        @Override

        public void run() {

            try {

                System.out.println(Thread.currentThread().getName()+"第1个100米");

                cyclicBarrier.await();

                System.out.println(Thread.currentThread().getName()+"第2个100米");

                cyclicBarrier.await();

                System.out.println(Thread.currentThread().getName()+"第3个100米");

                cyclicBarrier.await();

            } catch (InterruptedException e) {

                e.printStackTrace();

            } catch (BrokenBarrierException e) {

                e.printStackTrace();

            }

        }

    }

}