package Thread;

import java.util.Random;
import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ExchangerTest {

    public static void main(String[] args) {
        ExecutorService executorService=Executors.newCachedThreadPool();
        final Exchanger<String> exchanger=new Exchanger<String>();
        
        executorService.execute(new RunnableTest("A",exchanger));
        executorService.execute(new RunnableTest("B",exchanger));
    }
}

class RunnableTest implements Runnable{
    private String data;
    private Exchanger<String> exchanger;
    
    public RunnableTest(String data,Exchanger<String> exchanger){
        this.data=data;
        this.exchanger=exchanger;
    }

    @Override
    public void run() {

        try {
            System.out.println(Thread.currentThread().getName()+"  data:"+data);
            Thread.sleep(new Random().nextInt(1000));
            String swapData=exchanger.exchange(data);
            System.out.println(Thread.currentThread().getName() +"have swap data "+swapData);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    
}