CyclicBarrier

作者: 尉昌达 | 来源:发表于2020-07-07 08:11 被阅读0次

简单用法:

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();
            
        }
    }

输出:

满人了
满人了
满人了
满人了
满人了

相关文章

网友评论

    本文标题:CyclicBarrier

    本文链接:https://www.haomeiwen.com/subject/gzvoqktx.html