CyclicBarrier简单用法

简单用法:
public static void main(String[] args) {
//CyclicBarrier barrier = new CyclicBarrier(20);
    CyclicBarrier barrier = new CyclicBarrier(20, () -> System.out.println("满人了")); //每满20会执行
    /*CyclicBarrier barrier = new CyclicBarrier(20, new Runnable() {
        @Override
        public void run() {
            System.out.println("满人,发车");
        }
    });*/
    for(int i=0; i<100; i++) {
            new Thread(()->{
                try {
                    barrier.await(); //这边阻塞,每到满20会继续执行下去
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        
    }
}
输出:
满人了
满人了
满人了
满人了
满人了


请使用浏览器的分享功能分享到微信等