Java并发多线程编程——并发工具类Exchanger

Posted 2021-07-30 小志的博客

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了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<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);
   }

    //定义一个客户端方法
    public void clientMethod(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);

    }
    
    //测试类
    public static void main(String[] args) {
        Demo d =new Demo();

        //实例化Exchanger
        Exchanger<String> 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();
    }
}