当前位置:首页 > 开发 > 编程语言 > 多线程 > 正文

java 多线程之 CyclicBarrier

发表于: 2014-09-13   作者:annan211   来源:转载   浏览:
摘要: CyclicBarrier (周期障碍)类可以帮助同步,它允许一组线程等待整个线程组到达公共屏障点。CyclicBarrier 是使用整型变量构造的,其确定组中的线程数。当一个线程到达屏障时(通过调用 CyclicBarrier.await()),它会被阻塞,直到所有线程都到达屏障,然后在该点允许所有线程继续执行。与CountDownLatch不同的是,CyclicBarrier 所有公共线程都到
CyclicBarrier (周期障碍)类可以帮助同步,它允许一组线程等待整个线程组到达公共屏障点。CyclicBarrier 是使用整型变量构造的,其确定组中的线程数。当一个线程到达屏障时(通过调用 CyclicBarrier.await()),它会被阻塞,直到所有线程都到达屏障,然后在该点允许所有线程继续执行。与CountDownLatch不同的是,CyclicBarrier 所有公共线程都到达后,可以继续执行下一个目标点,而CountDownLatch第一次到达指定点后,也就是记数器减制零,就无法再次执行下一目标工作。

CyclicBarrier初始时还可带一个Runnable的参数,
此Runnable任务在CyclicBarrier的数目达到后,所有其它线程被唤醒前被执行。
在涉及一组固定大小的线程的程序中,这些线程必须不时地互相等待,此时 CyclicBarrier 很有用


应用场景:需要所有的子任务都完成时,才执行主任务,这个时候就可以选择使用CyclicBarrier。

package cyclicBarrier;

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierDemo {

	public static final int count = 3;

	public static void main(String[] args) {
		final CyclicBarrier cyclicBarrier = new CyclicBarrier(CyclicBarrierDemo.count,new Runnable(){
			@Override
			public void run() {
/*此处可看做主线程任务 可单独成一个类*/
				System.out.println(" all .....");
			}
		});

		CyclicBarrierThread demoThread = new CyclicBarrierThread(cyclicBarrier);
		for(int i=0;i<12;i++){
			new Thread(demoThread).start();
		}


	}
}

class CyclicBarrierThread implements Runnable{
	CyclicBarrier cyclicBarrier ;

	public CyclicBarrierThread(CyclicBarrier cyclicBarrier){
		this.cyclicBarrier = cyclicBarrier;
	}

	@Override
	public void run() {
		try {
			System.out.println(Thread.currentThread().getName()+"  is waiting...");
			cyclicBarrier.await();
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (BrokenBarrierException e) {
			e.printStackTrace();
		}
	}
}




执行结果:
Thread-0  is waiting...
Thread-1  is waiting...
Thread-2  is waiting...
 all .....
Thread-3  is waiting...
Thread-4  is waiting...
Thread-5  is waiting...
 all .....
Thread-6  is waiting...
Thread-7  is waiting...
Thread-8  is waiting...
 all .....
Thread-9  is waiting...
Thread-10  is waiting...
Thread-11  is waiting...
 all .....

java 多线程之 CyclicBarrier

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号