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