标签：
java.util.concurrent
Class Exchanager<V>
用于实现两个线程之间元素的交换。每个线程在完成一定的事务后想与另外一个线程交换数据，第一个拿出数据的线程一直等待第一个拿出
数据的线程，直到两个线程都拿出数据，才能进行数据交换。Exchanger对于遗传数学和管道设计应用也许很有用。
1 class FillAndEmpty { 2 Exchanger<DataBuffer> exchanger = new Exchanger<DataBuffer>(); 3 DataBuffer initialEmptyBuffer = ... 4 DataBuffer initialFullBuffer = ... 5 6 class FillingLoop implements Runnable { 7 public void run() { 8 DataBuffer currentBuffer = initialEmptyBuffer; 9 try { 10 while (currentBuffer != null) { 11 addToBuffer(currentBuffer); 12 if (currentBuffer.isFull()) 13 currentBuffer = exchanger.exchange(currentBuffer); 14 } 15 } catch (InterruptedException ex) { ... handle ... } 16 } 17 } 18 19 class EmptyingLoop implements Runnable { 20 public void run() { 21 DataBuffer currentBuffer = initialFullBuffer; 22 try { 23 while (currentBuffer != null) { 24 takeFromBuffer(currentBuffer); 25 if (currentBuffer.isEmpty()) 26 currentBuffer = exchanger.exchange(currentBuffer); 27 } 28 } catch (InterruptedException ex) { ... handle ...} 29 } 30 } 31 32 void start() { 33 new Thread(new FillingLoop()).start(); 34 new Thread(new EmptyingLoop()).start(); 35 } 36 }
程序分析：
有两个线程，一个是填充数据缓存，一个是消耗数据缓存。两个线程都是通过while语句来对各自的DataBuffer类型的数据进行判断。说明这是一个循环生产与消费的类型。
当填充线程将缓存容器填充满了之后，交到"交易平台"Exchanger；当消费线程从当前的缓存容器中拿取缓存数据直至为空时，就将缓存容器交到"交易平台"Exchanger。
假设消费线程比较早的启动了，此时缓存容器中数据为空，因此它会将其提交到Exchanger，但是此时，消费线程的exchange并不会返回值，而是阻塞于此。当填充线程
将缓存容器填充满，交到Exchanger后，消费线程的exchange会返回消费线程提交到Exchanger的空的缓存容器；与此同时，消费线程从exchange唤醒并返回填充线程
提交到Exchanger的填充好数据的缓存容器。
标签：
原文地址：http://www.cnblogs.com/feijishuo/p/4543582.html
