volatile关键字解析:
http://mp.weixin.qq.com/s?src=3×tamp=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 ; } } }
相关推荐
`ThreadDemo`可能是一个简单的示例程序,它演示了如何使用`CyclicBarrier`来控制多个线程的同步行为。通常,这样的示例会创建多个线程,每个线程执行一些任务,然后在`CyclicBarrier`上等待,直到所有线程都完成任务...
下面是一个简单的CyclicBarrier使用示例。假定有五个线程需要协作完成一个任务,在五个线程都到达某个执行点后,才允许它们继续执行后续的操作。示例中的CyclicBarrier设置为需要五个线程到达屏障点。每个线程在完成...
CyclicBarrier的使用以及注意事项
java并发编程中CountDownLatch和CyclicBarrier的使用借鉴 java并发编程中CountDownLatch和CyclicBarrier是两个非常重要的线程控制和调度工具,经常被用于解决多线程程序设计中的线程等待问题。本文将对...
- 使用CyclicBarrier实现多线程分治策略,每个子任务完成后来一次全局计算的例子。 - 线程间的异常处理,包括中断和超时的处理。 - 结合Future和ExecutorService,进一步提高并发性能和灵活性。 - 在大型项目中的...
Java并发实例之CyclicBarrier的使用 CyclicBarrier是Java中的一种多线程并发控制实用工具,和CountDownLatch非常类似,它也可以实现线程间的计数等待,但是它的功能比CountDownLatch更加复杂且强大。CyclicBarrier...
在游戏场景中,如果四个玩家需要同时开始游戏,就可以使用CyclicBarrier。`CyclicBarrier(int parties, Runnable barrierAction)`构造函数接受两个参数,`parties`表示需要等待的线程数,`barrierAction`是所有线程...
Java多线程之CyclicBarrier的使用方法 Java多线程之CyclicBarrier的使用方法是Java多线程编程中的一种同步机制,用于实现多个线程之间的同步协作。CyclicBarrier是Java 5中引入的一种同步机制,用于让多个线程等待...
使用CyclicBarrier时,可以指定一个栅栏动作,当所有线程都达到屏障点后,会执行这个动作。这可以是一个在执行其他同步点操作之前需要执行的任务。 然而,CyclicBarrier有其局限性。它不支持重置屏障,如果需要重用...
1. **重复使用性**:与CountDownLatch不同,CyclicBarrier可以在所有线程都达到屏障点后重置,允许再次使用。这意味着一旦所有线程都完成各自的任务并调用await()方法,屏障将被重置,计数器恢复到初始值,可以进行...
CyclicBarrier的主要特点在于它是循环使用的,也就是说,一旦所有等待的线程都被释放,该CyclicBarrier就可以被重用,适用于需要多次在多个线程间同步的场景。 CyclicBarrier的典型应用场景包括:多线程同时开始...
CyclicBarrier是一种在Java并发编程中广泛使用的同步工具,它允许多个线程在执行到某个共同的同步点时彼此等待。当所有线程都达到这个同步点后,它们将被释放并继续执行后续任务。这种机制非常适合需要多个线程协作...
- **可重用性**:`CyclicBarrier`是可循环使用的,而`CountDownLatch`一旦计数到零就不能再使用。 - **屏障点动作**:`CyclicBarrier`允许指定当所有线程到达屏障点时执行的动作,而`CountDownLatch`没有这个功能。 ...
本文将详细介绍CountDownLatch和CyclicBarrier的工作原理、使用场景以及如何在实际项目中应用它们。 CountDownLatch和CyclicBarrier是Java并发编程中两个非常有用的同步工具,它们在不同的场景下有着各自的优势。...
Java并发系列之CyclicBarrier源码分析 CyclicBarrier是Java并发系列中的一种同步工具类,用于实现一组线程相互等待。当所有线程都到达某个屏障点后,再进行后续的操作。下面是对CyclicBarrier源码的详细分析。 ...
用CyclicBarrier,reentrantlock,condition来完成同时购买,同步购买的功能 JUC系列之模拟抢票(N人同时抢票,票不足系统补仓,N-M人继续抢票) http://blog.csdn.net/crazyzxljing0621/article/details/77891620
`CyclicBarrier`的名字来源于它的可重用性,一旦一组线程通过了屏障,它可以重置并再次使用,而不是像`CountDownLatch`那样只能使用一次。 在上述的测试代码中,我们创建了一个`CyclicBarrier`实例,设置了线程数为...
下面是一个使用CyclicBarrier的典型例子,展示了一个并行分解问题的解决过程: ```java class Solver { final int N; final float[][] data; final CyclicBarrier barrier; class Worker implements Runnable...
Java中的`CyclicBarrier`是用于多线程同步的一个强大工具,主要应用于一组线程需要在继续执行之前等待其他线程到达某个特定点的情况。它允许开发者定义一个屏障点,只有当所有参与的线程都到达这个屏障点时,它们才...