`

CyclicBarrier使用

    博客分类:
  • java
 
阅读更多

 

volatile关键字解析:

http://mp.weixin.qq.com/s?src=3&timestamp=1474600039&ver=1&signature=fA4OwtcYwsEBwff*JKCl2mg-fR9TBZAoKJwxenYeMQ1ltg03UfyoEHJbhNg6pJANiba4TJn8M5knDiJL5m8IhhvE0eZkBtft7f0Y57719vpwqrZQ27FH3STrgvN5ZLzYjZ3pA4gYF*N*jQ5oGuo5wA==

 

 

同步辅助类,让N个线程互相等待,子线程结束后,可以启动另一个线程进行汇总  

 

 * 场景设想:

 *    有一个公司要对3个部门,分别进行工资统计,然后进行对比 ,和汇总

 *    但每个部门的数据还是比较大的, 这时候启动3个线程

 *    当3个线程全部执行结束了,在进行汇总计算总工资数目 

 

 

public class CyclicBarrierLatchTest2 {
	
	public static Integer num1;
	public static Integer num2;
	public static Integer num3;
	public static Integer total ;
	public static void main(String[] args) {
		 
		//所有线程执行完毕标识
		final ExecutorService executor = Executors.newFixedThreadPool(3) ; 
		CyclicBarrier bar = new CyclicBarrier(4 , new Runnable() {
			@Override
			public void run() {
				CyclicBarrierLatchTest2.total = CyclicBarrierLatchTest2.num1+ 
						CyclicBarrierLatchTest2.num2+CyclicBarrierLatchTest2.num3 ; 
				System.out.println( "最后计算结果:"+CyclicBarrierLatchTest2.total);
				executor.shutdown();
			}
		}); 
		
		try {
			for(int i=1;i<4;i++){
				Thread.sleep(500);//利用sleep,说明工人开始时间不同
				executor.execute( new SlaveThread3(bar,i));
				//new Thread(new SlaveThread3(bar,i)).start();
			}
			bar.await();
		} catch (InterruptedException e1) {
			e1.printStackTrace();
		}catch ( Exception e) {
			e.printStackTrace();
		}
		 
		System.out.println("主任务完成。。");
	}
	
}


//工人类
class SlaveThread3  extends Thread{
	 
	private CyclicBarrier  bar  ; 
	private int flag ; 
 
	public SlaveThread3( CyclicBarrier bar ,Integer flag ){
		this.bar = bar ;  
		this.flag= flag ; 
	}
	
	@Override
	public void run() {
		long start = System.currentTimeMillis() ; 
		System.out.println( "线程"+flag+"起止时间"+start);
		
		try {
			takeUp() ;
			//当前工人用力完毕,结束
			bar.await();
		} catch ( Exception e) {
			e.printStackTrace();
		}  
		 
		System.out.println( "线程"+flag+"结束时间"+start);
	}
	
	//抬起
	public void takeUp(){
		 if(flag==1){ //线程1数据统计
			 CyclicBarrierLatchTest2.num1 = 1 ;
		 }else if(flag==2){//线程2数据统计
			 CyclicBarrierLatchTest2.num2 = 1 ;
		 }else if(flag==3){//线程3数据统计
			 CyclicBarrierLatchTest2.num3 = 1 ;
		 }
	}
}

 

 

 

分享到:
评论

相关推荐

    CyclicBarrier的用法

    `ThreadDemo`可能是一个简单的示例程序,它演示了如何使用`CyclicBarrier`来控制多个线程的同步行为。通常,这样的示例会创建多个线程,每个线程执行一些任务,然后在`CyclicBarrier`上等待,直到所有线程都完成任务...

    CyclicBarrier的使用以及注意事项

    CyclicBarrier的使用以及注意事项

    java并发编程中CountDownLatch和CyclicBarrier的使用借鉴.pdf

    java并发编程中CountDownLatch和CyclicBarrier的使用借鉴 java并发编程中CountDownLatch和CyclicBarrier是两个非常重要的线程控制和调度工具,经常被用于解决多线程程序设计中的线程等待问题。本文将对...

    CountDownLatch和CyclicBarrier用法实例大全

    - 使用CyclicBarrier实现多线程分治策略,每个子任务完成后来一次全局计算的例子。 - 线程间的异常处理,包括中断和超时的处理。 - 结合Future和ExecutorService,进一步提高并发性能和灵活性。 - 在大型项目中的...

    Java并发实例之CyclicBarrier的使用

    Java并发实例之CyclicBarrier的使用 CyclicBarrier是Java中的一种多线程并发控制实用工具,和CountDownLatch非常类似,它也可以实现线程间的计数等待,但是它的功能比CountDownLatch更加复杂且强大。CyclicBarrier...

    java并发编程中CountDownLatch和CyclicBarrier的使用.pdf

    在游戏场景中,如果四个玩家需要同时开始游戏,就可以使用CyclicBarrier。`CyclicBarrier(int parties, Runnable barrierAction)`构造函数接受两个参数,`parties`表示需要等待的线程数,`barrierAction`是所有线程...

    java多线程之CyclicBarrier的使用方法

    Java多线程之CyclicBarrier的使用方法 Java多线程之CyclicBarrier的使用方法是Java多线程编程中的一种同步机制,用于实现多个线程之间的同步协作。CyclicBarrier是Java 5中引入的一种同步机制,用于让多个线程等待...

    CyclicBarrier用法.docx

    1. **重复使用性**:与CountDownLatch不同,CyclicBarrier可以在所有线程都达到屏障点后重置,允许再次使用。这意味着一旦所有线程都完成各自的任务并调用await()方法,屏障将被重置,计数器恢复到初始值,可以进行...

    Java中的CyclicBarrier类最全讲义

    - **可重用性**:`CyclicBarrier`是可循环使用的,而`CountDownLatch`一旦计数到零就不能再使用。 - **屏障点动作**:`CyclicBarrier`允许指定当所有线程到达屏障点时执行的动作,而`CountDownLatch`没有这个功能。 ...

    Java中的CountDownLatch与CyclicBarrier:深入理解与应用实践

    本文将详细介绍CountDownLatch和CyclicBarrier的工作原理、使用场景以及如何在实际项目中应用它们。 CountDownLatch和CyclicBarrier是Java并发编程中两个非常有用的同步工具,它们在不同的场景下有着各自的优势。...

    Java并发系列之CyclicBarrier源码分析

    Java并发系列之CyclicBarrier源码分析 CyclicBarrier是Java并发系列中的一种同步工具类,用于实现一组线程相互等待。当所有线程都到达某个屏障点后,再进行后续的操作。下面是对CyclicBarrier源码的详细分析。 ...

    CyclicBarrier,reentrantlock,condition模拟抢票

    用CyclicBarrier,reentrantlock,condition来完成同时购买,同步购买的功能 JUC系列之模拟抢票(N人同时抢票,票不足系统补仓,N-M人继续抢票) http://blog.csdn.net/crazyzxljing0621/article/details/77891620

    Java中CyclicBarrier的用法分析

    `CyclicBarrier`的名字来源于它的可重用性,一旦一组线程通过了屏障,它可以重置并再次使用,而不是像`CountDownLatch`那样只能使用一次。 在上述的测试代码中,我们创建了一个`CyclicBarrier`实例,设置了线程数为...

    JAVA CyclicBarrier类详解.docx

    下面是一个使用CyclicBarrier的典型例子,展示了一个并行分解问题的解决过程: ```java class Solver { final int N; final float[][] data; final CyclicBarrier barrier; class Worker implements Runnable...

    java线程并发cyclicbarrier类使用示例

    Java中的`CyclicBarrier`是用于多线程同步的一个强大工具,主要应用于一组线程需要在继续执行之前等待其他线程到达某个特定点的情况。它允许开发者定义一个屏障点,只有当所有参与的线程都到达这个屏障点时,它们才...

    CountDownLatch 和 CyclicBarrier 的运用(含AQS详解)

    - 使用 CyclicBarrier 初始化 N 个线程,这些线程需要共同完成一个任务,只有当所有线程都准备好了之后,它们才能一起开始执行。 **实践案例:** 假设我们有一个复杂的任务,需要分阶段完成,而且每个阶段都需要...

    Java并发编程(CyclicBarrier)实例详解

    在实际应用中,我们可以使用CyclicBarrier来控制多个线程之间的协作,例如,在游戏中,我们可以使用CyclicBarrier来控制四个玩家之间的协作,每个玩家需要到达某个关卡时,其他玩家也需要到达该关卡时,所有玩家才能...

    28 人齐了,一起行动—CyclicBarrier详解.pdf

    4. CyclicBarrier 的一个重要特性是它可以循环使用。一旦所有线程完成当前轮次的同步,计数器会自动重置,允许下一轮同步。 在实际编程中,CyclicBarrier 可用于多种场景,例如多线程计算的初始化阶段,所有参与...

    java并发编程专题(九)----(JUC)浅析CyclicBarrier

    CyclicBarrier 的使用场景有很多,例如,在一个游戏中,所有玩家都需要等待其他玩家到达某个点时,可以使用 CyclicBarrier 来实现。又例如,在一个科学计算中,多个线程需要等待其他线程完成计算时,也可以使用 ...

    详解java CountDownLatch和CyclicBarrier在内部实现和场景上的区别

    它的核心概念是“代”,每个使用CyclicBarrier的事件都对应一个代,当所有参与线程到达barrier点时,这一代结束,然后可以开始下一轮。CyclicBarrier的`lock`字段用于保护屏障的入口,`trip`条件变量用于线程在...

Global site tag (gtag.js) - Google Analytics