package com.xz.thread.Exchanger;

import java.util.concurrent.Exchanger;

/**
 * @description:
 * @author: xz
 * @create: 2021-05-31 21:56
 */
public class Demo {

   //定義一個(gè)服務(wù)端方法
   public void serverMethod(Exchanger<String> exchanger){
       System.out.println("【服務(wù)端】方法開(kāi)始執(zhí)行");

       //睡眠1秒鐘
       try {
           Thread.sleep(1000);
       } catch (InterruptedException e) {
           e.printStackTrace();
       }

       //定義服務(wù)端數(shù)據(jù)
       String data="serverData";

       //等待另一個(gè)線程到達(dá)此交換點(diǎn)（除非當(dāng)前線程為interrupted），然后將給定對(duì)象傳輸給它，接收其對(duì)象作為回報(bào)。
       String exchangeData="";
       try {
           exchangeData=exchanger.exchange(data);
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
       System.out.println("服務(wù)端原數(shù)據(jù)="+"serverData,"+" 交換后的數(shù)據(jù)=" + exchangeData);
   }

    //定義一個(gè)客戶端方法
    public void clientMethod(Exchanger<String> exchanger){
        System.out.println("【客戶端】方法開(kāi)始執(zhí)行");

        //睡眠3秒鐘
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        //定義客戶端數(shù)據(jù)
        String data="clientData";

        //等待另一個(gè)線程到達(dá)此交換點(diǎn)（除非當(dāng)前線程為interrupted），然后將給定對(duì)象傳輸給它，接收其對(duì)象作為回報(bào)。
        String exchangeData="";
        try{
            exchangeData =exchanger.exchange(data);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("客戶端原數(shù)據(jù)="+"clientData, "+"交換后的數(shù)據(jù)=" + exchangeData);

    }
    
    //測(cè)試類
    public static void main(String[] args) {
        Demo d =new Demo();

        //實(shí)例化Exchanger
        Exchanger<String> exchanger =new Exchanger();

        //第一個(gè)線程
        new Thread(new Runnable() {
            @Override
            public void run() {
                d.serverMethod(exchanger);
            }
        }).start();

        //第二個(gè)線程
        new Thread(new Runnable() {
            @Override
            public void run() {
                d.clientMethod(exchanger);
            }
        }).start();
    }
}