CyclicBarrier是所有线程都到了指定的个数，才开始执行下边的代码。
public class CyclicBarrierDemo {
// private static String[] arr = {"小王","小张","小李","小赵","小丽","小陈","小孙","小郭","小吴","小钱"};
private static String[] arr = {"小王","小张","小李","小赵","小丽"};
public static void main(String[] args)throws Exception{
changjing();
}
public static void changjing()throws Exception{
CyclicBarrier cyclicBarrier = new CyclicBarrier(5,new Runnable() {
@Override
public void run() {
System.out.println("5人已来,可以开席了");
}
});
for (int i = 0; i < 10; i++) {
final int index = i;
Thread.sleep(1000);
new Thread(()->{
try {
System.out.println(arr[index] + "要来了");
cyclicBarrier.await();
System.out.println(arr[index] + "开始吃了");
} catch (Exception e) {
}
},"线程" + i).start();
}
}
}
- 输出的结果（5个人都执行到了await方法，然后就可以执行run方法了，之后就可以执行之后的代码了）
小王要来了
小李要来了
小赵要来了
小张要来了
小丽要来了
5人已来,可以开席了
小丽开始吃了
小王开始吃了
小赵开始吃了
小张开始吃了
小李开始吃了