JDK5.0新特性系列---11.5.4线程 同步装置之Exchanger
/**
* Exchanger让两个线程互换信息
* 实例模拟服务生和顾客,服务生往空杯子中倒水,顾客从装满水的杯子中喝水,然后互换杯子,服务生接着倒水,顾客接着喝水.
*/
/**
* 使用Exchanger的关键技术点如下:
* 1.初始化Exchanger对象时,可以通过泛型指定杯子能交换的信息类型.如"new Exchanger<String>;"表示只能交换String类型的信息
* 2.Exchanger的exchange方法表示当前线程准备交换信息,等待其他线程与它交换信息.当有其他线程调用该Exchanger对象的exchange方法时,立即交换信息
*/
public class ExchangerTest {
//描述一个装水的杯子
public static class Cup{
private boolean full = false; //标识杯子是否有水
public Cup(boolean full){
this.full = full;
}
//添水,假设需要5s
public void addWater(){
if(!this.full){
try{
Thread.sleep(5000);
}catch(InterruptedException e){
}
this.full = true;
}
}
//喝水,假设需要10s
public void drinkWater(){
if(this.full){
try{
Thread.sleep(10000);
}catch(InterruptedException e){
}
this.full = false;
}
}
}
public static void testExchanger(){
//初始化一个Exchanger,并规定可交换的信息类型是杯子
final Exchanger<Cup> exchanger = new Exchanger<Cup>();
//初始化一个空的杯子和装满水的杯子
final Cup initialEmptyCup = new Cup(false);
final Cup initialFullCup = new Cup(true);
//服务生线程
class Waiter implements Runnable{
public void run(){
Cup currentCup = initialEmptyCup;
try{
int i = 0;
while(i < 2){
System.out.println("服务生开始往杯子里倒水: " + System.currentTimeMillis());
//往空的杯子里倒水
currentCup.addWater();
System.out.println("服务生添水完毕: " + System.currentTimeMillis());
//杯子满后和顾客的空杯子交换
System.out.println("服务生等待与顾客交换杯子: " + System.currentTimeMillis());
currentCup = exchanger.exchange(currentCup);
System.out.println("服务生与顾客交换杯子完毕: " + System.currentTimeMillis());
i++;
}
}catch(InterruptedException ex){
}
}
}
//顾客线程
class Customer implements Runnable{
public void run(){
Cup currentCup = initialFullCup;
try{
int i = 0;
while(i < 2){
System.out.println("顾客开始喝水: " + System.currentTimeMillis());
//把杯子里的水喝掉
currentCup.drinkWater();
System.out.println("顾客喝水完毕: " + System.currentTimeMillis());
//将空杯子和服务生的满杯子交换
System.out.println("顾客等待与服务生交换杯子: " + System.currentTimeMillis());
exchanger.exchange(currentCup);
System.out.println("顾客与服务生交换杯子完毕: " + System.currentTimeMillis());
i++;
}
}catch(InterruptedException ex){
}
}
}
new Thread(new Waiter()).start();
new Thread(new Customer()).start();
}
public static void main(String... args){
ExchangerTest.testExchanger();
}
}
/**
Waiter是模拟服务生的线程,首先往空杯子中添水,然后调用Exchanger的exchange方法,等待和别人交换杯子.Customer是模拟了顾客的线程,首先把装满水的杯子喝光,然后调用Exchange的exchange方法,等待和别人交换杯子.当服务生和顾客都准备交换杯子时,由Exchanger将服务生手中装满水的杯子和顾客手中的空杯子交换.服务生可以继续倒水,而顾客可以继续喝水.
*/
转载于:https://www.cnblogs.com/taven/archive/2011/12/17/2291477.html
JDK5.0新特性系列---11.5.4线程 同步装置之Exchanger相关推荐
- JDK5.0新特性系列---11.5.3线程 同步装置之CyclicBarrier
import java.util.Random; import java.util.concurrent.CyclicBarrier; /** * CyclicBarrier维持一个计数器,与Coun ...
- JDK5.0新特性系列---11.4线程 Condition
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util ...
- JDK5.0新特性系列---目录
JDK5.0新特性系列---目录 JDK5.0新特性系列---1.自动装箱和拆箱 JDK5.0新特性系列---2.新的for循环 JDK5.0新特性系列---3.枚举类型 JDK5.0新特性系列--- ...
- JDK5.0新特性--可变参数
2019独角兽企业重金招聘Python工程师标准>>> /*** 可变参数*/ public class VariableParamater {/*** 统计2个或多个数的和*/pu ...
- JDK5.0新特性之:泛型
文/陈刚 2005-11-09 一.前言 泛型这个词在现在的JAVA挺时髦,光从字面上你是无法知道它代表些什么东东的,所以我们还是不要从字面去理解,而是从一些实例去了解它吧. 二.泛型之前的日子 JD ...
- C# 3.0新特性系列(1):隐含类型局部变量
一.隐含类型局部变量简介 在C#3.0中增加了很多新的语言特性,如果有一个局部变量被声明为var,这个声明被视为隐含类型局部变量声明,然后由编译器根据局部变量初始化表达式来推断变量的类型.如下面的声明 ...
- jdk5.0新特性—— 枚举
为什么80%的码农都做不了架构师?>>> 目录 1.枚举的简介 2.枚举的api的操作 3.项目中枚举的实例 ===================== ...
- C#3.0 新特性系列(6) Extension Methods
You can use Extension Methods to add methods to existing types without declaring a new derived type, ...
- Android5.0,6.0,7.0,8.0新特性整理
背景 Android5.0(Android Lollipop)是谷歌公司2014年10月发布的全新安卓系统,至今已经两年多.然而由于国产手机对安卓ROM的深度定制或修改,以及手机厂商.芯片制造商.运营 ...
最新文章
- 【亲测可用】改变鼠标样式
- 前端知识之HTML内容
- FPGA详细芯片结构
- 乐视欠122亿的图标给后浪的启示
- SQL Server 2016 – PolyBase教程
- Ubuntu16.04.1安装Caffe(GPU)
- kotlin枚举_Kotlin枚举班
- iOS 证书, provision profile作用
- vue中的静态资源打包
- 淘宝转化率突然下降怎么办?原来是这些原因
- 迪杰斯特拉(Dijkstra)算法详解,通俗易懂
- 2017年高教社杯全国大学生数学建模竞赛(A题)
- minigui 编译与使用
- fore-each操作数组
- teambition、Tower、worktile 、trello 等任务管理工具哪个好?
- 开发群发微信图文消息,正文中的图片却不显示问题
- HarmonyOS上玩“语音识别”
- 大数据处理与分析方向主要干什么_大数据分析_方向_方法与工具
- centos上安装cdh2.6的方法
- 查询快递单号物流,筛选出代收的单号