【java并发】线程同步工具CyclicBarrier的使用

  上一节中总结了Semaphore同步工具的使用,Semaphore主要提供了一个记数信号量,允许最大线程数运行。CyclicBarrier是另一个同步工具,这一节主要来总结一下CyclicBarrier的使用。先看一下官方的对CyclicBarrier的介绍:

一个同步辅助类,它允许一组线程互相等待,直到到达某个公共屏障点 (common barrier point)。在涉及一组固定大小的线程的程序中,这些线程必须不时地互相等待,此时 CyclicBarrier 很有用。因为该 barrier 在释放等待线程后可以重用,所以称它为循环 的 barrier。

  我的解释是这样的:

CyclicBarrier 可以使不同的线程彼此等待,在不同的线程都执行完了后,再执行下面的程序。比如A、B、C三个同学要去玩,大巴在校门口,A、B、C分别从各自的寝室出来,先后到达大巴处,先来的必须等待,直到三个同学都来了,大巴才能走。他们要玩两个地方M和N,到了M处,三个同学又各自去玩了,玩完后各自回到大巴上,先回来的必须等待,直到三个同学都到了,大巴才能到N处,这个大巴可以循环利用。这个大巴就是CyclicBarrier。

  CyclicBarrier 同步工具相对来说比较简单,因为功能很明确,下面写一个CyclicBarrier 的示例代码:

public class CyclicBarrierTest {

    public static void main(String[] args) {
        ExecutorService service = Executors.newCachedThreadPool();
        final CyclicBarrier cb = new CyclicBarrier(3); //设置要三个线程等待,都执行完了再往下执行

        System.out.println("初始化:当前有" + (cb.getNumberWaiting() + "个线程在等待"));

         //3个任务
        for (int i = 0; i < 3; i++) {

            Runnable run = new Runnable() {
                public void run() {
                    try {
                        Thread.sleep((long)(Math.random()*10000));
                        System.out.println(Thread.currentThread().getName()
                                + "即将到达集合点1,当前已有" + (cb.getNumberWaiting()+1) + "个线程到达,"
                                + (cb.getNumberWaiting()==2?"都到齐了,去集合点2!":"正在等候……"));
                        // 访问完后,释放 ,如果屏蔽下面的语句,则在控制台只能打印3条记录,之后线程一直阻塞
                        cb.await(); //等待 

                        Thread.sleep((long)(Math.random()*10000));
                        System.out.println(Thread.currentThread().getName()
                                + "即将到达集合点2,当前已有" + (cb.getNumberWaiting()+1) + "个线程到达,"
                                + (cb.getNumberWaiting()==2?"都到齐了,去集合点3!":"正在等候……"));
                        cb.await();

                        Thread.sleep((long)(Math.random()*10000));
                        System.out.println(Thread.currentThread().getName()
                                + "即将到达集合点3,当前已有" + (cb.getNumberWaiting()+1) + "个线程到达,"
                                + (cb.getNumberWaiting()==2?"都到齐了,执行完毕!":"正在等候……"));
                        cb.await();

                    } catch (Exception e) {
                    }
                }
            };
            service.execute(run);  //执行任务
        }  

        service.shutdown(); //关闭线程
    }
}

  从代码中可以看出,CyclicBarrier 的使用主要有两点,一是初始化,二是调用await()方法。这个await()方法也就是官方解释中的“公共屏障点”,到了这个点,所有线程都得等待,直到规定数量的线程全部到达才能往下执行。看一下运行效果:

初始化:当前有0个线程在等待

pool-1-thread-3即将到达集合点1,当前已有1个线程到达,正在等候……

pool-1-thread-2即将到达集合点1,当前已有2个线程到达,正在等候……

pool-1-thread-1即将到达集合点1,当前已有3个线程到达,都到齐了,去集合点2!

pool-1-thread-2即将到达集合点2,当前已有1个线程到达,正在等候……

pool-1-thread-3即将到达集合点2,当前已有2个线程到达,正在等候……

pool-1-thread-1即将到达集合点2,当前已有3个线程到达,都到齐了,去集合点3!

pool-1-thread-3即将到达集合点3,当前已有1个线程到达,正在等候……

pool-1-thread-1即将到达集合点3,当前已有2个线程到达,正在等候……

pool-1-thread-2即将到达集合点3,当前已有3个线程到达,都到齐了,执行完毕!

  CyclicBarrier 的应用场合也很明显:在某种需求中,比如一个大型的任务,常常需要分配好多子任务去执行,只有当所有子任务都执行完成时候,才能执行主任务,这时候,就可以选择CyclicBarrier了。

  可以再确切一点:假如我们需要统计全国的业务数据,其中各省的数据库是独立的,也就是说按省分库。并且统计的数据量很大,统计过程也比较慢。为了提高性能,快速计算。我们采取并发的方式,多个线程同时计算各省数据,最后再汇总统计,在这里CyclicBarrier就非常有用。

  关于CyclicBarrier 同步工具就总结这么多吧!

  

  相关阅读:http://blog.csdn.net/column/details/bingfa.html



—–乐于分享,共同进步!

—–更多文章请看:http://blog.csdn.net/eson_15

时间: 2024-10-19 22:12:24

【java并发】线程同步工具CyclicBarrier的使用的相关文章

Java 并发 线程同步

Java 并发 线程同步 @author ixenos 同步 1.异步线程本身包含了执行时需要的数据和方法,不需要外部提供的资源和方法,在执行时也不关心与其并发执行的其他线程的状态和行为 2.然而,大多数实际的多线程应用中,两个或两个以上的线程需要共享对同一数据的存取,这将产生同步问题(可见性和同步性的丢失) 比如两个线程同时执行指令account[to] += amount,这不是原子操作,可能被处理如下: a)将account[to]加载到寄存器 b)增加amount c)将结果写回acco

【JAVA并发】同步工具类

同步工具类主要包括闭锁(如CountDownLatch),栅栏(如CyclicBarrier),信号量(如Semaphore)和阻塞队列(如LinkedBlockingQueue)等: 使用同步工具类可以协调线程的控制流: 同步工具类封装了一些状态,这些状态决定线程是继续执行还是等待,此外同步工具类还提供了修改状态的方法: 下面将简单介绍以上同步工具类: 闭锁 可以让一个线程等待一组事件发生后(不一定要线程结束)继续执行: 以CountDownLatch为例,内部包含一个计数器,一开始初始化为一

Java多线程_同步工具CyclicBarrier

CyclicBarrier概念:CyclicBarrier是多线程中的一个同步工具,它允许一组线程互相等待,直到到达某个公共屏障点.形象点儿说,CyclicBarrier就是一个屏障,要求这一组线程中的每一个线程都要等待其他的线程执行完成,即这一组线程全部来到屏障前(全部执行完成),屏障才会打开,放这一组线程全部通过去执行下一个操作. 构造方法: CyclicBarrier(int parties):需要声明需要拦截的线程数: CyclicBarrier(int parties, Runnabl

JAVA 并发编程-线程同步工具类(十二)

本文主要介绍一些java线程同步工具类,并不进行具体讲解,当有需要时,可以再去结合实例学习. 信号灯(Semaphore) 应用场景举例: 例如公司的打卡系统,如果有一个打卡机,那么一次就只能有一个人打卡,其余的人就被阻塞住,打卡完以后就可由下一个人打卡.如果有3个打卡机,那么一次就允许3个人或者少于三个人打卡,其余的人就得等待打卡机空闲下来才能继续打卡. 结果: 已进入1个线程,还可进入2个 已进入2个线程,还可进入1个 已进入3个线程,还可进入0个 空余出1个 已进入4个线程,还可进入0个

Java 并发 线程的生命周期

Java 并发 线程的生命周期 @author ixenos 线程的生命周期 线程状态: a)     New 新建 b)     Runnable 可运行 c)     Running 运行 (调用getState()时显示为Runnable) d)     Blocked 阻塞 i.          I/O阻塞 (不释放锁) I/O操作完成解除阻塞,进入Runnable状态 ii.          同步阻塞(不释放锁) 运行的线程在获取对象的同步锁时,若该同步锁被别的线程占用,则JVM会

Java 并发 线程属性

Java 并发 线程属性 @author ixenos 线程优先级 1.每当线程调度器有机会选择新线程时,首先选择具有较高优先级的线程 2.默认情况下,一个线程继承它的父线程的优先级 当在一个运行的线程A里,创建另一个线程B的时候,那么A是父线程,B是子线程.当在一个运行的线程A里,创建线程B,然后又创建了线程C,这时候虽然B比C创建早,可是B并不是C的父线程,而A是B和C的父线程. 3.线程的优先级高度依赖于系统,当虚拟机依赖于宿主机平台的线程实现机制时,Java线程的优先级被映射到宿主机平台

Java 并发 线程的优先级

Java 并发 线程的优先级 @author ixenos 低优先级线程的执行时刻 1.在任意时刻,当有多个线程处于可运行状态时,运行系统总是挑选一个优先级最高的线程执行,只有当线程停止.退出或者由于某些原因不执行的时候,低优先级的线程才可能被执行 2.两个优先级相同的线程同时等待执行时,那么运行系统会以round-robin的方式选择一个线程执行(即轮询调度,以该算法所定的)(Java的优先级策略是抢占式调度!) 3.被选中的线程可因为一下原因退出,而给其他线程执行的机会: 1) 一个更高优先

Java多线程基础(四)Java传统线程同步通信技术

Java多线程基础(四)Java传统线程同步通信技术 编写代码实现以下功能 子线程循环10次,接着主线程循环100次,接着又回到子线程循环10次,接着再回到主线程又循环100次,如此循环50次. 分析 1)子线程循环10次与主线程循环100次必须是互斥的执行,不能出现交叉,下面代码中通过synchronized关键字实现此要求: 2)子线程与主线程必须交替出现,可以通过线程同步通信技术实现,下面代码中通过bShouldSub变量实现此要求: 其他需要注意的地方 1)其中business变量必须声

Java中线程同步的理解 - 其实应该叫做Java线程排队

Java中线程同步的理解 我们可以在计算机上运行各种计算机软件程序.每一个运行的程序可能包括多个独立运行的线程(Thread). 线程(Thread)是一份独立运行的程序,有自己专用的运行栈.线程有可能和其他线程共享一些资源,比如,内存,文件,数据库等. 当多个线程同时读写同一份共享资源的时候,可能会引起冲突.这时候,我们需要引入线程"同步"机制,即各位线程之间要有个先来后到,不能一窝蜂挤上去抢作一团. 同步这个词是从英文synchronize(使同时发生)翻译过来的.我也不明白为什么