package servlet.test;
import java.util.concurrent.Exchanger;
public class ExchangerTest {
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
Exchanger<String> exchanger = new Exchanger<String>();
CustomThreadExchanger customThreadExchanger1 = new CustomThreadExchanger(exchanger, "A");
CustomThreadExchanger customThreadExchanger2 = new CustomThreadExchanger(exchanger, "B");
new Thread(customThreadExchanger1).start();
new Thread(customThreadExchanger2).start();
}
}
class CustomThreadExchanger implements Runnable{
private Exchanger<String> exchanger = null;
private String s = null;
public CustomThreadExchanger(Exchanger<String> exchanger, String s){
this.exchanger = exchanger;
this.s = s;
}
@Override
public void run() {
// TODO Auto-generated method stub
String previous = s;
try {
s = (String) exchanger.exchange(s);
System.out.println(previous + " become " + s);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}