标签：函数 ack eset 场景 阻塞 简介 main 一个 trace
CyclicBarrier的字面意思是可循环使用的屏障，它的主要作用是，让一组线程到达一个屏障时被阻塞，知道最后一个线程到达屏障时，屏障才会打开，所有被屏障拦截的线程才会继续运行。
1、简介：
CyclicBarrier默认的构造方法是CyclicBarrier(int parties),其中参数标识屏障拦截的线程数量，每个线程调用await方法告诉CyclicBarrier我已经到达了屏障，然后当前线程被阻塞。
package com.test; import java.util.concurrent.CyclicBarrier; public class CiclicBarrierTest { static CyclicBarrier c = new CyclicBarrier(2); public static void main(String[] args) { new Thread(new Runnable() { @Override public void run() { try { c.await(); } catch (Exception e) { e.printStackTrace(); } System.out.println(1); } }).start(); try { c.await(); } catch (Exception e) { e.printStackTrace(); } System.out.println(2); } }
如果把new CyclicBarrier(2)修改擦new CyclicBarrier(3) 则主线程和子线程会永远等待，因为没有第三个线程去执行await方法。既没有第三个线程到达屏障，所以之前到达屏障的两个线程都不会继续执行。
CyclicBarrier还提供一个更高级的构造函数，CyclicBarrier(int parties, Runnable barrier-Action)用于在线程到达屏障时，优先执行barrierAction,方便处理更复杂的业务场景:
package com.test; import java.util.concurrent.CyclicBarrier; public class CiclicBarrierTest { static CyclicBarrier c = new CyclicBarrier(2, new A()); public static void main(String[] args) { new Thread(new Runnable() { @Override public void run() { try { c.await(); } catch (Exception e) { e.printStackTrace(); } System.out.println(1); } }).start(); try { c.await(); } catch (Exception e) { e.printStackTrace(); } System.out.println(2); } public static class A implements Runnable { @Override public void run() { System.out.println(3); } } } // 结果 3 1 2
CyclicBarrier和CountDownLatch的区别:
CountDownLatch的计数器只能使用一次，而CyclicBarrier的计数器可以使用reset()方法重置。所以CyclicBarrier能处理更为复杂的业务场景。
CyclicBarrier还提供其他有用的方法，比如getNumberWaiting方法可以获得被阻塞的线程数量. isBroken()方法用来了解阻塞的线程是否被中断。
标签：函数 ack eset 场景 阻塞 简介 main 一个 trace
原文地址：https://www.cnblogs.com/gouge/p/9122811.html
