api解释:类似CountDownLatch,但是是一个加法计数器。从0开始计数
具体方法: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