Java并发工具类（三）Exchanger

在J.U.C并发包中提供了一些工具类，可以供我们在日常的开发中，根据不同的情况去进行一些相关的并发控制，具体的类有：

CountDownLatch
Semaphore
Exchanger
CyclicBarrier

Exchanger

概念

Exchanger是线程间协作的工具类,Exchanger用于进行线程间的数据交换,它提供一个同步点,在这个同步点,两个线程通过exchange方法交换(共享)彼此的数据。

实现

public static void main(String[] args) {  Exchanger<Integer> exchanger = new Exchanger<>();new Boss(exchanger).start();  new Employee(exchanger).start();  }
class Boss extends Thread {  Exchanger<Integer> exchanger = null;  public Boss(Exchanger<Integer> exchanger) {  super();  this.exchanger = exchanger;  }  @Override  public void run() {  int money = 0;for(int i=0;i<4;i++){money+=100000;try {exchanger.exchange(money);} catch (Exception e) {e.printStackTrace();}}}
}
class Employee extends Thread {  Exchanger<Integer> exchanger = null;  int money = 0;public Employee(Exchanger<Integer> exchanger) {  super();  this.exchanger = exchanger;  }  @Override  public void run() {  for(int i=0;i<4;i++){try {money = exchanger.exchange(money,2,TimeUnit.SECONDS) ;System.out.println(money>300000?"您好，鉴于您为公司创收较多，将被评为优秀员工":money+"您好，鉴于您为公司创收较少，年终奖没有了");} catch (Exception e) {e.printStackTrace();}}}
}

执行结果

您好，鉴于您为公司创收较多，将被评为优秀员工

Exchanger特性

Exchanger主要用于二个线程之间交换数据，如果有一个线程没执行exchange()方法,则会一直等待,线程会一直阻塞；避免的方法,可以设置等待时间:exchange(V x, long timeout, TimeUnit unit)

完整代码和相关依赖请见GitHub

https://github.com/dwyanewede/project-learn/tree/master/src/main/java/com/learn/demo/concurrent

Java并发工具类（三）Exchanger相关推荐

Java并发工具类(4):Exchanger相关介绍
Exchanger(交换者)是一个用于线程间协作的工具类.Exchanger用于进行线程间的数据交换.它提供一个同步点,在这个同步点两个线程可以交换彼此的数据.这两个线程通过exchange方法交换数 ...
彻底理解Java并发：Java并发工具类
本篇内容包括:Java 并发工具类的介绍.使用方式与 Demo,包括了 CountDownLatch(线程计数器).CyclicBarrier(回环栅栏).Semaphore(信号量) 以及 Exch ...
J.U.C之并发工具类：Exchanger
本文来说下J.U.C之并发工具类:Exchanger 文章目录概述应用示例实现分析 exchange()方法本文小结概述前面分别介绍了CyclicBarrier.CountDownLatc ...
Java并发工具类（闭锁CountDownLatch）
并发工具类系列: Java并发工具类(闭锁CountDownLatch) Java并发工具类(栅栏CyclicBarrier) Java并发工具类(信号量Semaphore) 闭锁是一种同步工具类,可 ...
死磕Java并发：J.U.C之并发工具类：Exchanger
作者:chenssy 来源:Java技术驿站前面三篇博客分别介绍了CyclicBarrier.CountDownLatch.Semaphore,现在介绍并发工具类中的最后一个Exchange.Exc ...
j.u.c系列（11）---之并发工具类：Exchanger
写在前面前面三篇博客分别介绍了CyclicBarrier.CountDownLatch.Semaphore,现在介绍并发工具类中的最后一个Exchange.Exchange是最简单的也是最复杂的,简 ...
Java高并发编程（十）：Java并发工具类
1. 等待多线程完成的CountDownLatch CountDownLatch允许一个或多个线程等待其他线程完成操作. 1.1 应用场景假如有这样一个需求:我们需要解析一个Excel里多个shee ...
Java并发工具类：CountDownLatch、Semaphore、CyclicBarrier、Exchanger、Phaser
本文目录: 1.CountDownLatch(闭锁) 1.CountDownLatch 例子 2.CyclicBarrier(循环栅栏) 1.CyclicBarrier 例子 2.CountDownL ...
Java并发工具类-循环屏障CyclicBarrier
CyclicBarrier简介 CyclicBarrier API 构造方法 await方法 reset方法使用样例 CyclicBarrier源码详解 CyclicBarrier中属性构造方法及 ...

Java并发工具类（三）Exchanger

Java并发工具类（三）Exchanger

Exchanger

概念

实现

执行结果

Exchanger特性

完整代码和相关依赖请见GitHub

相关文章推荐

Java并发工具类（三）Exchanger相关推荐

最新文章

热门文章