文档章节

Phaser 工作方式与CyclicBarrier类似,但是可以定义多个阶段

噼里啪啦嘣
 噼里啪啦嘣
发布于 2016/05/08 20:33
字数 191
阅读 9
收藏 0
import java.util.concurrent.Phaser;

/**
 * Created by zyBourn on 15/12/25.
 */
public class Entity {
    /**
     * 工作方式与CyclicBarrier类似,但是可以定义多个阶段
     * Phaser()/Phaser(int num):使用指定0/num个party创建Phaser
     * register():注册party
     * arriveAndAdvance():到达时等待到所有party到达
     * arriveAndDeregister():到达时注销想成自己
     */
    public static void main(String[] args) {
        Phaser phaser=new Phaser(1);
        new Worker(phaser,"厨师").start();
        new Worker(phaser,"服务员").start();
        new Worker(phaser,"传菜员").start();
        for (int i=1;i<=3;i++){
            phaser.arriveAndAwaitAdvance();
            System.out.println("订单"+i+"完成!");
        }
        phaser.arriveAndDeregister();
        System.out.println("处理完成");
    }

}

class Worker extends Thread{
    private Phaser phaser;
    public Worker(Phaser phaser,String name){
        setName(name);
        this.phaser=phaser;
        phaser.register();
    }
    public void run(){
        for (int i = 0; i <=3; i++) {
            System.out.println("当前的订单是:"+i+":"+getName());
            if (i==3){
                phaser.arriveAndDeregister();
            }else {
                phaser.arriveAndAwaitAdvance();
            }
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}


© 著作权归作者所有

共有 人打赏支持
上一篇: Semaphore信号量
下一篇: lock
噼里啪啦嘣

噼里啪啦嘣

粉丝 1
博文 30
码字总数 8391
作品 0
杭州
后端工程师
私信 提问
JAVA 并发体系概览

Java并发包主要有以下部分构成: 同步对象 主要提供多个线程以何种方式进行通信协作 执行器 管理多线程,提供线程运行入口 锁 控制线程访问资源的顺序 原子操作 对Java的基本类型进行了封装,...

二两豆腐
2016/12/19
61
0
线程间通信剖析

CountDownLatch CountDownLatch适用场景 Java多线程编程中经常会碰到这样一种场景——某个线程需要等待一个或多个线程操作结束(或达到某种状态)才开始执行。比如开发一个并发测试工具时,主...

李矮矮
2016/10/17
2
0
Fork-Join及Phaser

1、Fork-Join fork/join是java7更新的一个新的轻量级任务执行框架,其主要目的是要更好滴利用底层平台上的多核CPU和多处理器来进行并行处理,解决问题时通常采用分治(divide and conquer)算...

xixicat
2014/08/06
0
0
JDK7中的Phaser

JDK7对并发编程提供了更好的支持,包括ThreadLocalRandom、ForkJoinPool、TransferQueue以及本文要讲述的Phaser。 JDK5中引入了CyclicBarrier和CountDownLatch这两个并发控制类,而JDK7中引入...

鉴客
2011/12/30
468
0
Java多线程编程之同步器

同步器 为每种特定的同步问题提供了解决方案 Semaphore Semaphore【信号标;旗语】,通过计数器控制对共享资源的访问。 测试类: 线程写法: 执行结果【以下所有输出结果中[]中为线程名称- 后...

拿客-三产
2016/08/11
6.2K
2

没有更多内容

加载失败,请刷新页面

加载更多

大数据教程(11.9)hive操作基础知识

上一篇博客分享了hive的简介和初体验,本节博主将继续分享一些hive的操作的基础知识。 DDL操作 (1)创建表 #建表语法CREATE [EXTERNAL] TABLE [IF NOT EXISTS] table_name [(col_name ...

em_aaron
今天
0
0
OSChina 周四乱弹 —— 我家猫真会后空翻

Osc乱弹歌单(2019)请戳(这里) 【今日歌曲】 @我没有抓狂 :#今天听这个# 我艇牛逼,百听不厌,太好听辣 分享 Led Zeppelin 的歌曲《Stairway To Heaven》 《Stairway To Heaven》- Led Z...

小小编辑
今天
1
0
node调用dll

先安装python2.7 安装node-gyp cnpm install node-gyp -g 新建一个Electron-vue项目(案例用Electron-vue) vue init simulatedgreg/electron-vue my-project 安装electron-rebuild cnpm ins......

Chason-洪
今天
3
0
scala学习(一)

学习Spark之前需要学习Scala。 参考学习的书籍:快学Scala

柠檬果过
今天
3
0
通俗易懂解释网络工程中的技术,如STP,HSRP等

导读 在面试时,比如被问到HSRP的主备切换时间时多久,STP几个状态的停留时间,自己知道有这些东西,但在工作中不会经常用到,就老是记不住,觉得可能还是自己基础不够牢固,知识掌握不够全面...

问题终结者
昨天
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部