Exchanger——Java两个线程间交换数据的工具类

Exchanger是一个用于线程间数据交换的协做工具类，它提供一个同步点，两个线程能够交换彼此的数据，注意这里只能是两个线程。

两个线程经过exchange() 方法来交换数据，当第一个线程执行到exchange()时，会产生阻塞，直到另外一个线程也执行exchange(),以后两个线程均可以获得对方的执行结果。示例代码以下：

public class ExchangerTest {
   private static final Exchanger<String> exgr = new Exchanger<String>();
   
   private static ExecutorService threadPool = Executors.newFixedThreadPool(2);
   
   public static void main(String[] args) {
	   threadPool.execute(new Runnable(){
		@Override
		public void run() {
			try {
				String A = "this is a A";
				String B = exgr.exchange(A);
				System.out.println("a 线程里 a:"+A+" b:"+B);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	   });
	   
	   threadPool.execute(new Runnable(){
			@Override
			public void run() {
				try {
					String B = "this is a B";
					String A = exgr.exchange(B);
					System.out.println("B 线程里 a:"+A+" b:"+B);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
		   });
	   
	   threadPool.shutdown();
}
}

执行结果：

B 线程里 a:this is a A b:this is a B
a 线程里 a:this is a A b:this is a B

 若是两个线程有一个一直没有执行exchange()方法，则会一直等待，若是要避免一直等待，能够使用exchange(V x,long timeout,TimeUnit unit)设置最大等待时长。