package com.atguigu.javademo.juc;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.TimeUnit;
public class JUCDEmo4 {
public static void main(String[] args) throws Exception{
CountDownLatch latch = new CountDownLatch(6);//一共要执行6个线程
CyclicBarrier barrier = new CyclicBarrier(2,()->{
System.out.println("[达到屏障点]开始执行任务，士兵车辆出发");
});//达到两个线程就执行后续的操作
for (int x = 0; x < 6; x++) {
new Thread(()->{
System.out.println("[等待屏障调度]"+Thread.currentThread().getName()+“进入待执行线程操作”);
try {
TimeUnit.SECONDS.sleep(1);
barrier.await();//等待屏障点调度
System.err.println("[通过屏障调度]"+Thread.currentThread().getName()+“执行线程操作”);
latch.countDown();
}catch (Exception e){}
},“士兵-”+x).start();
}
latch.await();
System.out.println(“主线程【所有的士兵分配完毕】”);
}
}
CountDownLatch采用倒计数的方式进行一次的 数据处理，当计数达到0的时候才进行线程的恢复执行；
CyclicBarriere采用循环的计数形式（每一次是依据数量的减少得到的统计，当屏障的数量为0之后才会触发后续的线程执行），当达到屏障点设置的时候指定的几个线程才会开始调度执行，该操作可以进行多次。
