Java并发工具类Exchanger的相关知识总结

Java并发工具类Exchanger的相关知识总结

一、Exchanger的理解

Exchanger 属于java.util.concurrent包；

Exchanger 是 JDK 1.5 开始提供的一个用于两个工作线程之间交换数据的封装工具类;

一个线程在完成一定的事务后想与另一个线程交换数据，则第一个先拿出数据的线程会一直等待第二个线程，直到第二个线程拿着数据到来时才能彼此交换对应数据。

二、Exchanger类中常用方法

public Exchanger() 无参构造方法。表示创建一个新的交换器。

public V exchange(V x) 等待另一个线程到达此交换点（除非当前线程为 interrupted ），然后将给定对象传输给它，接收其对象作为回报。

（1）、x ：表示可以交换的对象

public V exchange(V x, long timeout, TimeUnit unit) 等待另一个线程到达此交换点（除非当前线程为 interrupted或指定的等待时间已过），然后将给定对象传输给它，接收其对象作为回报。

（1）、 x ：交换对象

（2）、timeout ：等待的最长时间

（3）、unit ：timeout参数的时间单位

三、Exchanger类的使用示例

案例场景

模拟客户端和服务端交换数据。

1、代码

package com.xz.thread.Exchanger;

import java.util.concurrent.Exchanger;

/**

* @description:

* @author: xz

* @create: 2021-05-31 21:56

*/

public class Demo {

//定义一个服务端方法

public void serverMethod(Exchanger exchanger){

System.out.println("【服务端qqJOO】方法开始执行");

//睡眠1秒钟

try {

Thread.sleep(1000);

} catch (InterruptedException e) {

e.printStackTrace();

}

//定义服务端数据

String data="serverData";

//等待另一个线程到达此交换点（除非当前线程为interrupted），然后将给定对象传输给它，接收其对象作为回报。

String exchangeData="";

try {

exchangeData=exchanger.exchange(data);

} catch (InterruptedException e) {

e.printStackTrace();

}

System.out.println("服务端原数据="+"serverData,"+" 交换后的数据=" + exchangeData);

}

//定义一个客户端方法

public void clientMethod(Exchanger exchanger){

System.out.println("【客户端】方法开始执行");

//睡眠3秒钟

try {

Thread.sleep(3000);

} catch (InterruptedException e) {

e.printStackTrace();

}

//定义客户端数据

String data="clientData";

qqJOO //等待另一个线程到达此交换点（除非当前线程为interrupted），然后将给定对象传输给它，接收其对象作为回报。

String exchangeData="";

try{

exchangeData =exchanger.exchange(data);

} catch (InterruptedException e) {

e.printStackTrace();

}

System.out.println("客户端原数据="+"clientData, "+"交换后的数据=" + exchangeData);

}

//测试类

public static void main(String[] args) {

Demo d =new Demo();

//实例化Exchanger

Exchanger exchanger =new Exchanger();

//第一个线程

new Thread(new Runnable() {

@Override

public void run() {

d.serverMethod(exchanger);

}

}).start();

//第二个线程

new Thread(new Runnable() {

@Override

public void run() {

d.clientMethod(exchanger);

}

}).start();

}

}

2、运行main函数，输出结果如下：

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。