package com.test.concurrence;

 

import java.util.concurrent.Exchanger;

 

public class ExchangerTest {

 

public static void main(String[] args) {

//待交换数据的类型为字符串。

final Exchanger<String>  exchanger = new Exchanger<String>();

String[] tags = new String[]{"A","B"};

for(int j=0;j<2;j++){

final String tag = tags[j];

new Thread( new Runnable(){

@Override

public void run(){

for(int i=0;i<10;i++){

try {

String old = tag+i;

//执行效果：对方变成old，自己得到result。

Object result = exchanger.exchange(old);

System.out.println( old + " => " + result +" , " + Thread.currentThread().getName());

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

}).start();

}

 

 

}

 

}