今天给大家带来的文章是Java工具类Exchanger的相关知识总结,文中有非常详细的介绍及代码示例,对正在学习java的小伙伴们很有帮助,需要的朋友可以参考下
一、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("【服务端】方法开始执行"); //睡眠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"; //等待另一个线程到达此交换点（除非当前线程为interrupted），然后将给定对象传输给它，接收其对象作为回报。 String exchangeData=""; try{ exchangeData =exchanger.exchange(data); } catch (InterruptedException <mark style="color:transparent">来源gaodaimacom搞#^代%!码&网</mark>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函数，输出结果如下：
以上就是Java并发工具类Exchanger的相关知识总结的详细内容，更多请关注gaodaima搞代码网其它相关文章！
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：Java并发工具类Exchanger的相关知识总结
转载请注明原文链接：Java并发工具类Exchanger的相关知识总结
