簡(jiǎn)單用法: public static void main(String[] args) { //CyclicBarrier barrier = new CyclicBarrier(20); CyclicBarrier barrier = new CyclicBarrier(20, () -> System.out.println("滿人了")); //每滿20會(huì)執(zhí)行 /*CyclicBarrier barrier = new CyclicBarrier(20, new Runnable() { @Override public void run() { System.out.println("滿人,發(fā)車"); } });*/ for(int i=0; i<100; i++) { new Thread(()->{ try { barrier.await(); //這邊阻塞,每到滿20會(huì)繼續(xù)執(zhí)行下去 } catch (InterruptedException e) { e.printStackTrace(); } catch (BrokenBarrierException e) { e.printStackTrace(); } }).start(); } } 輸出: 滿人了 滿人了 滿人了 滿人了 滿人了 |
|
來(lái)自: 昵稱71567378 > 《待分類》