CyclicBarrier 栅栏 什么时候满了开始发车
- CyclicBarrier barrier = new CyclicBarrier(20, () -> System.out.println("满人"));满20人开始发车
- 每一个线程到达 barrier.await();都等着
- 当 barrier.await();到达20人就开始往下执行 ,发车
public class T07_TestCyclicBarrier {
public static void main(String[] args) {
CyclicBarrier barrier = new CyclicBarrier(20, () -> System.out.println("满人"));
for(int i=0; i<100; i++) {
new Thread(()->{
try {
barrier.await();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}).start();
}
}
}