1 编排线程

1.1 循环屏障(栅栏) CycliCBarrier

每个线程到达屏障后被阻隔并记录到达的总数，当总数等于预设的值后，这些线程都被"放行"，向下执行，之后屏障恢复为初始状态，可以再次使用。主要方法只有await。

static CyclicBarrier cyclicBarrier = new CyclicBarrier(10,()->{
        System.out.println("屏障已满，准备开始执行");
});
class R1 implements Runnable{
    @Override
    public void run() {
        System.out.println("到达屏障开始等待");
        try {
            cyclicBarrier.await();
            System.out.println("执行屏障后内容");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
@Test
public void CyclicBarrierTest(){
    for(int i=0;i<30;i++){
        new Thread(new R1()).start();
    }
}

打印结果：

到达屏障开始等待
到达屏障开始等待
到达屏障开始等待
到达屏障开始等待
到达屏障开始等待
到达屏障开始等待
到达屏障开始等待
到达屏障开始等待
到达屏障开始等待
到达屏障开始等待
屏障已满，准备开始执行
执行屏障后内容
执行屏障后内容
执行屏障后内容
执行屏障后内容
执行屏障后内容
执行屏障后内容
执行屏障后内容
执行屏障后内容
执行屏障后内容
执行屏障后内容

1.2 计数器 CountDownLatch

计数的位置和阻隔的位置是分离的，阻隔当前线程，在其他线程计数，当计数满了之后，"放行"当前线程。主要方法有countDown和await。

static CountDownLatch countDownLatch = new CountDownLatch(5);
class R2 implements Runnable{
    @Override
    public void run() {
        System.out.println("R2准备");
        countDownLatch.countDown();
        System.out.println("R2后续");

    }
}
class R3 implements Runnable{
    @Override
    public void run() {
        try {
            System.out.println("等待5个R2准备完成");
            countDownLatch.await();
            System.out.println("R3执行");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

    }
}
@Test
public void CountDownLatchTest(){
    new Thread(new R3()).start();
    for (int i=0;i<5;i++){
        new Thread(new R2()).start();
    }
}

打印：

等待5个R2准备完成
R2准备
R2后续
R2准备
R2后续
R2准备
R2后续
R2准备
R2后续
R2准备
R2后续
R3执行

CountDownLatch和栅栏非常像，也是await阻塞住，然后计数，记满了就放行。但是栅栏阻塞住的是每个线程，计数的也是这些线程。而Latch是阻塞住另外一个单独的线程，如上先阻塞住R3，然后记R2数，R2满了，给R3放行，并不阻塞R2自己。

场景选择：

1.3 相位器 Phaser

相位器能实现屏障和计数器，是最全能的。他主要4个方法arrive、register、arriveAndDeregister、awaitAdvance。

awaitAdvance接参数是期望第几阶段结束。 image

static Phaser phaser = new Phaser(3);
   
public static void main(String[] args) {
   for(int i=0;i<6;i++) {
      new Thread(() -> {
         try {
             Thread.sleep(1000L);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
         phaser.arrive();
         System.out.println(phaser.getPhase() + "-" + phaser.getRegisteredParties());
      }).start();
    }
    phaser.awaitAdvance(phaser.getPhase());
    phaser.awaitAdvance(phaser.getPhase());
 }

打印：

1-3
0-3
0-3
1-3
1-3
2-3

这里使用phaser阶段的概念进行了多阶段计数，phaser比计数器强的除了循环可用，还有一点就是可以动态修改计数的数值。phaser使用过程中需要注意同步可以参考之前的出的题目。