JUC辅助类CyclicBarrier

api解释:类似CountDownLatch,但是是一个加法计数器。从0开始计数JUC辅助类CyclicBarrier
具体方法:cyclicBarrier.await();等待到CyclicBarrier内规定数量,才会执行await内的语句。

具体代码如下:

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierDemo {
    public static void main(String[] args) {

        CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{
            System.out.println("召唤神龙");
        });

        for (int i = 1; i <=7; i++) {
            final int num=i;
            new Thread(()->{
                System.out.println(Thread.currentThread().getName()+"集齐了第"+num+"颗龙珠");
                try {
                    cyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }

    }
}

结果如下:

Thread-0集齐了第1颗龙珠
Thread-2集齐了第3颗龙珠
Thread-1集齐了第2颗龙珠
Thread-3集齐了第4颗龙珠
Thread-5集齐了第6颗龙珠
Thread-6集齐了第7颗龙珠
Thread-4集齐了第5颗龙珠
召唤神龙

Process finished with exit code 0

上一篇:控制并发流程


下一篇:JUC强大的辅助类讲解--->>>CyclicBarrier(循环栅栏)