[游戏开发]CyclicBarrier

一、介绍

CyclicBarrier线程同步屏障，他的使用场景是，等一组线程到达屏障后，然后再同时放行。

二、使用案例

@Slf4j
public class CylicBarrierExample {

    private final static CyclicBarrier CYLIC_BARRIER = new CyclicBarrier(5);
    public static void main(String[] args) throws Exception {
        for (int i = 0; i < 10; i++) {
            final  int num = i;
            Thread.sleep(1000);
            new Thread(()->{
                try {
                 ready(num);
               } catch (Exception e) {
                    e.printStackTrace();
                }

            }).start();
        }
    }
    public static void ready(int num) throws Exception {
        log.info(" ready this thread id is {} and i is {} ",Thread.currentThread().getName(),num);
        CYLIC_BARRIER.await();
        log.info(" continue .... this thread id is {} and i is {} ",Thread.currentThread().getName(),num);
    }
}

当调用await()时就会检查是否达到放行标准。

三、源码分析

CyclicBarrier内部是基于ReentrantLock的Condition实现的。
�Condiction

3.1 阻挡线程await()

// 部分代码省略
if (!timed)
      trip.await();
else if (nanos > 0L)
    nanos = trip.awaitNanos(nanos);

而trip就是Condiction。

3.2 何时释放栅栏

// 计算数器 - 1
int index = --count;
if (index == 0) {  // tripped
    // 通行标志
    boolean ranAction = false;
    try {
        final Runnable command = barrierCommand;
        if (command != null)
            command.run();
        ranAction = true;
        nextGeneration();
        return 0;
    } finally {
        if (!ranAction)
            // 核心方法内部进行放行
            breakBarrier();
    }
}



private void breakBarrier() {
        generation.broken = true;
        count = parties;
    // 调用condiction的signallAll() 方法
        trip.signalAll();
    }

3.3 小结

一组线程就相当于不同的选手在入场，condiction这个裁判，得所以的选手入场后，才会发出指令SignalAll()，让所有的选手任务.放行

3.4 参考

《并发编程艺术》