|
簡單用法: public static void main(String[] args) {
//CyclicBarrier barrier = new CyclicBarrier(20); CyclicBarrier barrier = new CyclicBarrier(20, () -> System.out.println("滿人了")); //每滿20會執(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會繼續(xù)執(zhí)行下去
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}).start();
}
}輸出: 滿人了 滿人了 滿人了 滿人了 滿人了 |
|
|
來自: 昵稱71567378 > 《待分類》