java并发编程包JUC线程同步CyclicBarrier语法示例

目录
  • 1.创建CyclicBarrier障碍
  • 2.在CyclicBarrier障碍处等待
  • 3.CyclicBarrierAction
  • 4.CyclicBarrier例子

在之前的文章中已经为大家介绍了java并发编程的工具:BlockingQueue接口、ArrayBlockingQueue、DelayQueue、LinkedBlockingQueue、PriorityBlockingQueue、SynchronousQueue、BlockingDeque接口、ConcurrentHashMap、CountDownLatch,本文为系列文章第十篇。

java.util.concurrent.CyclicBarrier提供了一种多线程彼此等待的同步机制,可以把它理解成一个障碍,所有先到达这个障碍的线程都将将处于等待状态,直到所有线程都到达这个障碍处,所有线程才能继续执行。

举个例子:CyclicBarrier的同步方式有点像朋友们约好了去旅游,在景点入口处集合,这个景点入口就是一个Barrier障碍,等待大家都到了才一起进入景点游览参观。 进入景点后大家去爬山,有的人爬得快,有的人爬的慢,大家约好了山顶集合,所以山顶就又是一个Barrier障碍,等待大家都到了山顶才一起下山。

下面是一张图来说明这个问题。

每个线程通过调用await(),在CyclicBarrier障碍处“彼此等待”,一旦所有的线程都到达了CyclicBarrier(都调用了CyclicBarrier方法),所有的线程将一起再次被唤醒继续执行。

1.创建CyclicBarrier障碍

当创建CyclicBarrier的时候,需要指定需要控制多少个线程同步。比如下面的CyclicBarrier设置为控制2个线程同步。

CyclicBarrier barrier = new CyclicBarrier(2);

2. 在CyclicBarrier障碍处等待

通过调用CyclicBarrier的await()方法进入等待状态,通常在线程完成自己的阶段性任务之后调用该方法。

barrier.await();

CyclicBarrier也提供了另一种方法指定等待超时的时间,当等待时间大于超时时间之后,即使还有其他的线程没调用await方法,该线程将自动唤醒继续执行。(朋友们约好了去旅游,等了10分钟你还不来,我就自己先去了)。

barrier.await(10, TimeUnit.SECONDS);

The waiting threads waits at theCyclicBarrieruntil either:

CyclicBarrier处等待的线程被释放,继续执行的条件(满足下面的任一条件即可)

  • 最后到达的线程调用了await() 方法
  • 该线程被另一个线程打断(另一个线程调用其interrupt()方法)。
  • 另一个处于等待状态的线程被打断
  • 另一个处于等待状态的线程在CyclicBarrier处等待时超时。
  • 某个外部线程调用了CyclicBarrier.reset()拆除障碍。

3. CyclicBarrier Action

CyclicBarrier Action 相对不太好理解,可以把它理解为障碍自身的行为。该Action动作是一个线程,所有的线程都到达障碍之后,该线程将被执行。

Runnable      barrierAction =   创建线程;
CyclicBarrier barrier  = new CyclicBarrier(2, barrierAction);

如果这段代码仍然无法理解CyclicBarrier Action的作用,看下面的例子。

4. CyclicBarrier 例子

下面的代码演示了如何使用CyclicBarrier进行线程同步:

Runnable barrier1Action = new Runnable() {
    public void run() {
        System.out.println("障碍1集合成功了,所有人都到了景点门口 ");
    }
};
Runnable barrier2Action = new Runnable() {
    public void run() {
        System.out.println("障碍2集合成功了,所有人都到了山顶");
    }
};
//障碍1 景点门口
CyclicBarrier barrier1 = new CyclicBarrier(2, barrier1Action);
//障碍2 山顶
CyclicBarrier barrier2 = new CyclicBarrier(2, barrier2Action);

//旅游计划,阶段目标一:景点门口集合
CyclicBarrierRunnable barrierRunnable1 =
        new CyclicBarrierRunnable(barrier1, barrier2);
//旅游计划,阶段目标二:爬山到山顶集合
CyclicBarrierRunnable barrierRunnable2 =
        new CyclicBarrierRunnable(barrier1, barrier2);
new Thread(barrierRunnable1).start();  //游客A,Thread-0
new Thread(barrierRunnable2).start();  //游客B,Thread-1

下面是一个线程类CyclicBarrierRunnable,启动一个就代表一个游客

public class CyclicBarrierRunnable implements Runnable{
    CyclicBarrier barrier1 = null;  //障碍1
    CyclicBarrier barrier2 = null;  //障碍2
    public CyclicBarrierRunnable( CyclicBarrier barrier1,CyclicBarrier barrier2) {
        this.barrier1 = barrier1;
        this.barrier2 = barrier2;
    }
    public void run() {
        try {
            Thread.sleep(1000);  //这里写出发去景点的过程代码
            System.out.println(Thread.currentThread().getName() +
                                " 到达景点门口");
            this.barrier1.await();
            Thread.sleep(1000);  //这里写爬山的过程代码
            System.out.println(Thread.currentThread().getName() +
                                " 爬山爬到山顶");
            this.barrier2.await();
            System.out.println(Thread.currentThread().getName() +
                                " 玩的不错,下山回家!");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (BrokenBarrierException e) {
            e.printStackTrace();
        }
    }
}

下面的输出是上文代码的执行打印结果,多执行几次上文的代码会发现Thread-0 和 Thread-1 在障碍1和障碍2处的到达先后顺序是不确定的,但是总是先到的等后到的再继续执行。

Thread-0 到达景点门口
Thread-1 到达景点门口
障碍1集合成功了,所有人都到了景点门口
Thread-1 爬山爬到山顶
Thread-0 爬山爬到山顶
障碍2集合成功了,所有人都到了山顶
Thread-0  玩的不错,下山回家!
Thread-1  玩的不错,下山回家!

以上就是java并发编程包JUC线程同步CyclicBarrier语法示例的详细内容,更多关于JUC CyclicBarrier线程同步语法的资料请关注我们其它相关文章!

(0)

相关推荐

  • Java并发实例之CyclicBarrier的使用

    最近一直整并发这块东西,顺便写点Java并发的例子,给大家做个分享,也强化下自己记忆,如果有什么错误或者不当的地方,欢迎大家斧正. CyclicBarrier是一种多线程并发控制实用工具,和CountDownLatch非常类似,它也可以实现线程间的计数等待,但是它的功能比CountDownLatch更加复杂且强大. CyclicBarrier的介绍 CyclicBarrier 的字面意思是可循环(Cyclic)使用的屏障(Barrier).它要做的事情是,让一组线程到达一个屏障(也可以叫同步点)

  • Java并发系列之CyclicBarrier源码分析

    现实生活中我们经常会遇到这样的情景,在进行某个活动前需要等待人全部都齐了才开始.例如吃饭时要等全家人都上座了才动筷子,旅游时要等全部人都到齐了才出发,比赛时要等运动员都上场后才开始.在JUC包中为我们提供了一个同步工具类能够很好的模拟这类场景,它就是CyclicBarrier类.利用CyclicBarrier类可以实现一组线程相互等待,当所有线程都到达某个屏障点后再进行后续的操作.下图演示了这一过程. 在CyclicBarrier类的内部有一个计数器,每个线程在到达屏障点的时候都会调用await

  • java多线程CyclicBarrier的使用案例,让线程起步走

    1.CyclicBarrier: 一个同步辅助类,用于协调多个子线程,让多个子线程在这个屏障前等待,直到所有子线程都到达了这个屏障时,再一起继续执行后面的动作. 2.使用场景举例: 年末公司组织团建,要求每一位员工周六上午8点[自驾车]到公司门口集合,然后[自驾车]前往目的地. 在这个案例中,公司作为主线程,员工作为子线程. 3.代码示例: package com.test.spring.support; import java.util.concurrent.BrokenBarrierExce

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

    Java并发编程(CyclicBarrier)实例详解 前言: 使用JAVA编写并发程序的时候,我们需要仔细去思考一下并发流程的控制,如何让各个线程之间协作完成某项工作.有时候,我们启动N个线程去做一件事情,只有当这N个线程都达到某一个临界点的时候,我们才能继续下面的工作,就是说如果这N个线程中的某一个线程先到达预先定义好的临界点,它必须等待其他N-1线程也到达这个临界点,接下来的工作才能继续,只要这N个线程中有1个线程没有到达所谓的临界点,其他线程就算抢先到达了临界点,也只能等待,只有所有这N

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

    上一篇我们介绍了CountDownlatch,我们知道CountDownlatch是"在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待",即CountDownLatch的作用是允许1或N个线程等待其他线程完成执行,而我们今天要介绍的CyclicBarrier则是允许N个线程相互等待. 1.CyclicBarrier简介 CyclicBarrier 的字面意思是可循环使用(Cyclic)的屏障(Barrier).它要做的事情是,让一组线程到达一个屏障(也可以叫同步点)

  • java并发编程包JUC线程同步CyclicBarrier语法示例

    目录 1.创建CyclicBarrier障碍 2.在CyclicBarrier障碍处等待 3.CyclicBarrierAction 4.CyclicBarrier例子 在之前的文章中已经为大家介绍了java并发编程的工具:BlockingQueue接口.ArrayBlockingQueue.DelayQueue.LinkedBlockingQueue.PriorityBlockingQueue.SynchronousQueue.BlockingDeque接口.ConcurrentHashMap

  • Java并发编程包中atomic的实现原理示例详解

    线程安全: 当多个线程访问某个类时,不管运行时环境采用何种调度方式或者这些进程将如何交替执行,并且在主调代码中不需要任何额外的同步或协调,这个类都能表现出正确的行为,那么就称这个类时线程安全的. 线程安全主要体现在以下三个方面: 原子性:提供了互斥访问,同一时刻只能有一个线程对它进行操作 可见性:一个线程对主内存的修改可以及时的被其他线程观察到 有序性:一个线程观察其他线程中的指令执行顺序,由于指令重排序的存在,该观察结果一般杂乱无序 引子 在多线程的场景中,我们需要保证数据安全,就会考虑同步的

  • java并发数据包Exchanger线程间的数据交换器

    java.util.concurrent.Exchanger可以用来进行数据交换,或者被称为“数据交换器”.两个线程可以使用Exchanger交换数据,下图用来说明Exchanger的作用 在下面的代码中 首先我们定义了一个Exchanger,用于数据交换 然后定义了两个线程对象bookExchanger1和bookExchanger2,两个线程都持有Exchanger交换器对象用于数据交换 两个线程中的每个线程都有自己的数据,比如下面代码中的String[] 书籍数组. public stat

  • Java并发编程进阶之线程控制篇

    目录 一.线程的基本概念 1.并行和并发 2.进程和线程 二.线程的运行状态 三.线程操作实践 1.线程两种定义方法 2.启动线程 3.同时定义和启动线程 4.线程弹出与暂停 5.线程等待与唤醒 6.线程中断 一.线程的基本概念 1.并行和并发 并行:多个CPU核心同时工作,处理不同的任务. 并发:多个任务交替使用 CPU 核心工作,以提高 CPU 利用率. 2.进程和线程 进程:程序的一次执行.由操作系统创建并分配资源,执行一个单独的任务. 进程是系统进行资源分配和调度的独立单位,每个进程都有

  • Java多线程编程中synchronized线程同步的教程

    0.关于线程同步 (1)为什么需要同步多线程? 线程的同步是指让多个运行的线程在一起良好地协作,达到让多线程按要求合理地占用释放资源.我们采用Java中的同步代码块和同步方法达到这样的目的.比如这样的解决多线程无固定序执行的问题: public class TwoThreadTest { public static void main(String[] args) { Thread th1= new MyThread1(); Thread th2= new MyThread2(); th1.st

  • Java并发编程之创建线程

    先讲述一下Java中的应用程序和进程相关的概念知识,然后再阐述如何创建线程以及如何创建进程.下面是本文的目录大纲: 一.Java中关于应用程序和进程相关的概念 二.Java中如何创建线程 三.Java中如何创建进程 一.Java中关于应用程序和进程相关的概念 在Java中,一个应用程序对应着一个JVM实例(也有地方称为JVM进程),一般来说名字默认为java.exe或者javaw.exe(windows下可以通过任务管理器查看).Java采用的是单线程编程模型,即在我们自己的程序中如果没有主动创

  • Java并发编程中构建自定义同步工具

    当Java类库没有提供适合的同步工具时,就需要构建自定义同步工具. 可阻塞状态依赖操作的结构 复制代码 代码如下: acquir lock on object state;//请求获取锁 while(precondition does not hold){//没有满足前提条件    release lock;//先释放锁    wait until precondition might hold;//等待满足前提条件    optionlly fail if interrupted or tim

  • Java并发编程面试之线程池

    目录 什么是线程池 线程池好处 线程池的执行流程 怎么用线程池 corePoolSize maximumPoolSize keepAliveTime unit workQueue threadFactory ejectedExecutionHandler 线程池参数如何设置? 监控线程池 总结 什么是线程池 是一种基于池化思想管理线程的工具.池化技术:池化技术简单点来说,就是提前保存大量的资源,以备不时之需.比如我们的对象池,数据库连接池等. 线程池好处 我们为什么要使用线程池,直接new th

  • java并发编程JUC CountDownLatch线程同步

    目录 java并发编程JUC CountDownLatch线程同步 1.CountDownLatch是什么? 2.CountDownLatch 如何工作 3.CountDownLatch 代码例子 java并发编程JUC CountDownLatch线程同步 CountDownLatch是一种线程同步辅助工具,它允许一个或多个线程等待其他线程正在执行的一组操作完成.CountDownLatch的概念在java并发编程中非常常见,面试也会经常被问到,所以一定要好好理解掌握. CountDownLa

  • Java并发编程之详解CyclicBarrier线程同步

    CyclicBarrier线程同步 java.util.concurrent.CyclicBarrier提供了一种多线程彼此等待的同步机制,可以把它理解成一个障碍,所有先到达这个障碍的线程都将将处于等待状态,直到所有线程都到达这个障碍处,所有线程才能继续执行. 举个例子:CyclicBarrier的同步方式有点像朋友们约好了去旅游,在景点入口处集合,这个景点入口就是一个Barrier障碍,等待大家都到了才一起进入景点游览参观. 进入景点后大家去爬山,有的人爬得快,有的人爬的慢,大家约好了山顶集合

随机推荐