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、代码

packagecom.xz.thread.Exchanger;importjava.util.concurrent.Exchanger;/**
 * @description:
 * @author: xz
 * @create: 2021-05-31 21:56
 */publicclassDemo{//定义一个服务端方法publicvoidserverMethod(Exchanger<String> 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);}//定义一个客户端方法publicvoidclientMethod(Exchanger<String> 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 e){
            e.printStackTrace();}System.out.println("客户端原数据="+"clientData, "+"交换后的数据="+ exchangeData);}//测试类publicstaticvoidmain(String[] args){Demo d=newDemo();//实例化ExchangerExchanger<String> exchanger=newExchanger();//第一个线程newThread(newRunnable(){@Overridepublicvoidrun(){
                d.serverMethod(exchanger);}}).start();//第二个线程newThread(newRunnable(){@Overridepublicvoidrun(){
                d.clientMethod(exchanger);}}).start();}}

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