modor
10/30/2017 - 8:47 AM

ExchangerTest

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();
		}
	}
}