说一说你对CyclicBarrier的理解（说说你对cyberdog的看法）

【死记硬背】

【概念】CyclicBarrier即循环栅栏，就是一个可以循环利用的屏障。它也是一个同步辅助类，允许两个或者多个线程在某个点上进行同步。

【原理】CyclicBarrier使用一个整形数进行初始化，这个数是需要在某个点上同步的线程数。当一个线程到达指定的点后，它将调用await()方法等待其他的线程。当线程调用await()方法后，CyclicBarrier将阻塞这个线程并使之休眠直到所有其他线程到达。当最后一个线程调用await()方法时，CyclicBarrier对象将唤醒所有在等待的线程，然后这些线程将继续执行。

【性质】CyclicBarrier与CountDownLatch有所不同，它可以被循环重置为初始状态，并把它的内部计数器重置成初始化时的值，而CountDownLatch只能使用一次。

【举例】比如公司组织员工爬山，提前分成了5组，每组6人，当每一组的人到齐后，可以开始爬山，这样可以循环5次，就可以用CyclicBarrier。

【答案解析】

CyclicBarrier的核心方法是await()，有两种方式：

// 无参的await()
public int await() throws InterruptedException, BrokenBarrierException {
  try {
    return dowait(false, 0L);
  } catch (TimeoutException toe) {
    throw new Error(toe); // cannot happen
  }
}
// 有参的await()
public int await(long timeout, TimeUnit unit)
throws InterruptedException,
  BrokenBarrierException,
  TimeoutException {
    return dowait(true, unit.toNanos(timeout));
  }

下面是同学一起分组去吃饭使用CyclicBarrier的Demo：

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class CyclicBarrierTest {
    private static final int THREAD_NUMBER = 3;
    private static CyclicBarrier sCyclicBarrier = new CyclicBarrier(
            THREAD_NUMBER, new Runnable() {
        @Override
        public void run() {
            System.out.println("大家都到达了宿舍楼下，一起出发吧。。。");
        }
    });
    public static void main(String[] args) {
        ExecutorService executorService = Executors
                .newFixedThreadPool(THREAD_NUMBER);
        for (int i = 0; i < THREAD_NUMBER; i++) {
            executorService.execute(new WalkFromDomitoryToCanteenRunnable(
                    sCyclicBarrier, "同学" + i));
        }
        try {
            Thread.sleep(3000);// 主线程睡眠
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("CyclicBarrier重用");
        for (int i = THREAD_NUMBER; i < THREAD_NUMBER * 2; i++) {
            executorService.execute(new WalkFromDomitoryToCanteenRunnable(
                    sCyclicBarrier, "同学" + i));
        }
        executorService.shutdown();
    }
    /**
     * 从宿舍到食堂线程
     */
    public static class WalkFromDomitoryToCanteenRunnable implements Runnable {
        private CyclicBarrier mCyclicBarrier;
        private String mName;
        public WalkFromDomitoryToCanteenRunnable(CyclicBarrier cyclicBarrier,
                                                 String name) {
            this.mCyclicBarrier = cyclicBarrier;
            this.mName = name;
        }
        @Override
        public void run() {
            System.out.println(mName + "开始从宿舍出发。。。");
            try {
                Thread.sleep(1000);
                mCyclicBarrier.await();// 等待别同学
                // 前往食堂
                System.out.println(mName + "开始从宿舍楼下出发。。。");
                Thread.sleep(1000);
                System.out.println(mName + "达到食堂。。。");
            } catch (InterruptedException e) {
                e.printStackTrace();
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
            }
        }
    }
}

【温馨提示】

点赞+收藏文章，关注我并私信回复【面试题解析】，即可100%免费领取楼主的所有面试题资料！