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

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

    震惊

    震惊

编辑推荐
以前在<<编写高质量代码-改善Java程序的151个建议>>一书中看到有一节的标题是“Cyclic
以前在<<编写高质量代码-改善Java程序的151个建议>>一书中看到有一节的标题是“Cyclic
一.概述 使用JAVA编写并发程序的时候,我们需要仔细去思考一下并发流程的控制,如何让各个线程之间协
进程 线程 main 和 run 的区别 /** *进程:是一个正在执行的程序 * 每一个进程执行都有一个执行顺序,
进程 线程 main 和 run 的区别 /** *进程:是一个正在执行的程序 * 每一个进程执行都有一个执行顺序,
当现在不适合这个操作,或是没有必要进行这个操作时就直接放弃这个操作而回去。这个就是Balking模式
进程 线程 main 和 run 的区别 /** *进程:是一个正在执行的程序 * 每一个进程执行都有一个执行顺序,
进程 线程 main 和 run 的区别 /** *进程:是一个正在执行的程序 * 每一个进程执行都有一个执行顺序,
进程 线程 main 和 run 的区别 /** *进程:是一个正在执行的程序 * 每一个进程执行都有一个执行顺序,
一个同步辅助类,它允许一组线程互相等待,直到到达某个公共屏障点 (common barrier point)。在涉及
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号