{ System.out.println(Thread.currentThread().getName() + "\t arrived."); try{ cyclicBarrier.await(); }catch (Exception e){ e.printStackTrace(); } }, String.valueOf(i)).start(); } } }"> { System.out.println(Thread.currentThread().getName() + "\t arrived."); try{ cyclicBarrier.await(); }catch (Exception e){ e.printStackTrace(); } }, String.valueOf(i)).start(); } } }"> { System.out.println(Thread.currentThread().getName() + "\t arrived."); try{ cyclicBarrier.await(); }catch (Exception e){ e.printStackTrace(); } }, String.valueOf(i)).start(); } } }">
public class CyclicBarrierDemo {
public static void main(String[] args) {
CyclicBarrier cyclicBarrier = new CyclicBarrier(7, () -> {
System.out.println("pass");
});
for(int i = 1; i <= 7; ++i){
final int temp = i;
new Thread(() -> {
System.out.println(Thread.currentThread().getName() + "\\t arrived.");
try{
cyclicBarrier.await();
}catch (Exception e){
e.printStackTrace();
}
}, String.valueOf(i)).start();
}
}
}