本文主要是介绍CyclicBarrier实例二,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
public class CyclicBarrierTest4 {public static void main(String[] args) throws InterruptedException {CyclicBarrier cyclicBarrier = new CyclicBarrier(5, new Runnable() {@Overridepublic void run() {//线程都到了之后,先执行这个System.out.println("各线程到齐后,由最后到达的线程执行该Action" + "," + Thread.currentThread().getName());}});for (int i = 0; i < 5; i++) {new Thread(new readNum(i, cyclicBarrier)).start();}//CyclicBarrier 可以重复利用,这个是CountDownLatch做不到的
// for (int i = 11; i < 16; i++) {
// new Thread(new readNum(i,cyclicBarrier)).start();
// }}static class readNum implements Runnable {private int id;private CyclicBarrier cyc;public readNum(int id, CyclicBarrier cyc) {
这篇关于CyclicBarrier实例二的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!