Exchanger简介

Exchanger是一个用于线程间协作的工具类。Exchanger用于进行线程间的数据交换。它提供一个同步点，在这个同步点，两个线程可以交换彼此的数据。这两个线程通过 exchange方法交换数据，如果第一个线程先执行exchange()方法，它会一直等待第二个线程也执行exchange()方法，当两个线程都到达同步点时，这两个线程就可以交换数据，将本线程生产出来的数据传递给对方

Exchanger使用介绍

Exchanger<T>用于在两个线程之间共享数据。该类仅提供一个重载方法exchange(T t)，其中exchange(V x, long timeout, TimeUnit unit)方法可以指定阻塞超时时间，下面通过一个来理解两个线程之间交换数据：

public class ExchangerDemo {static Exchanger<String> exgr = new Exchanger<>();public static void main(String[] args) {Thread taskA=new Thread(()->{try {String message = exgr.exchange("from A");System.out.println("A Task===>"+ message);} catch (InterruptedException e) {e.printStackTrace();}});Thread taskB=new Thread(()->{try {String message = exgr.exchange("from B");System.out.println("B Task===>"+ message);} catch (InterruptedException e) {e.printStackTrace();}});taskA.start();taskB.start();}
}

输出结果：

线程A，把数据传给了线程B，线程B，把数据传给了线程A

B Task===>from A
A Task===>from B

子线程与主线程间交换数据：

public class ExchangerDemo2 {static Exchanger<String> exchanger = new Exchanger<>();public static void main(String[] args) throws InterruptedException {Runnable childTask = () -> {try {String message = exchanger.exchange("来自子线程的数据");System.out.println("子线程： "+message);} catch (InterruptedException e) {Thread.currentThread().interrupt();throw new RuntimeException(e);}};//CompletableFuture java1.8中新增的异步编程类CompletableFuture<Void> result = CompletableFuture.runAsync(childTask);String msg = exchanger.exchange(" 来自主线程的数据");System.out.println("主线程： " +msg);result.join();}
}

输出结果：

子线程：  来自主线程的数据
主线程： 来自子线程的数据

Java并发工具Exchanger线程间交换数据相关推荐

Java并发编程--6.Exchanger线程间交换数据
在两个线程之间定义同步点,当两个线程都到达同步点时,他们交换数据结构,因此第一个线程的数据结构进入到第二个线程中,第二个线程的数据结构进入到第一个线程中在生产者-消费者情境模式中它包含了一个数缓冲区 ...
19、Java并发编程：线程间协作的两种方式：wait、notify、notifyAll和Condition
Java并发编程:线程间协作的两种方式:wait.notify.notifyAll和Condition 在前面我们将了很多关于同步的问题,然而在现实中,需要线程之间的协作.比如说最经典的生产者-消费者 ...
Java多线程研究（八）使用Exchange在多个线程间交换数据
比如生活中两个人,一个人有零食,另一个人有钱,他们两个想等价交换,对好口号在某个地方相见,一个人先到了之后,必须等另一个人带着需要的东西来了之后,才能开始hi交换. 代码: import java.u ...
java面试-Java并发编程(六)——线程间的通信
多条线程之间有时需要数据交互,下面介绍五种线程间数据交互的方式,他们的使用场景各有不同. 1. volatile.synchronized关键字 PS:关于volatile的详细介绍请移步至:Java ...
Java高并发编程（十）：Java并发工具类
1. 等待多线程完成的CountDownLatch CountDownLatch允许一个或多个线程等待其他线程完成操作. 1.1 应用场景假如有这样一个需求:我们需要解析一个Excel里多个shee ...
线程同步工具（七）在并发任务间交换数据
声明:本文是< Java 7 Concurrency Cookbook >的第三章, 作者: Javier Fernández González 译者:郑玉婷在并发任务间交换数据 Jav ...
【java】Java 中的 Exchanger 线程同步使用方法线程之间交换数据
1.概述转载:https://www.pdai.tech/md/java/thread/java-thread-x-juc-tool-exchanger.html 视频参考:https://www. ...
java 多线程共享变量两类问题_Java并发基础09. 多个线程间共享数据问题
先看一个多线程间共享数据的问题: 设计四个线程,其中两个线程每次对data增加1,另外两个线程每次对data减少1. 从问题来看,很明显涉及到了线程间通数据的共享,四个线程共享一个 data,共同操作 ...
java 多个线程共享数据_【java并发】多个线程间共享数据
先看1个多线程间同享数据的问题: 设计4个线程,其中两个线程每次对data增加1,另外两个线程每次对data减少1. 从问题来看,很明显触及到了线程间通数据的同享,4个线程同享1个data,共同操作1 ...

Java并发工具Exchanger线程间交换数据

本文目录

Exchanger简介

Exchanger使用介绍

Java并发工具Exchanger线程间交换数据相关推荐

最新文章

热门文章