Exchanger： 两个线程 间 交换 数据

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

/*
*	Exchanger： 两个线程  间 交换 数据
*		exchange() 等待另一个线程到达此交换点（除非当前线程被中断），
*					然后将给定的对象传送给该线程，并接收该线程传来的对象。
*    即：  当线程为单数条时，那么总有条线程是交换不到数据的，该线程一直等待。。
*
*    设计 一个小游戏：相亲随机配对
*/
public class ExchangerTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
final Exchanger<String> exchanger = new Exchanger<String>();
final List<String> males = new ArrayList<String>();
males.add("张三");
males.add("李四");
males.add("王五");males.add("赵六");males.add("卓七");
final List<String> females = new ArrayList<String>();
females.add("张晓");
females.add("李丽");
females.add("王梅");females.add("赵雅");females.add("卓红");
final Random random = new Random();
final int nums = 5;

Runnable r1 = new Runnable() {

@Override
public void run() {
// TODO Auto-generated method stub
for (int i = 0; i < nums; i++) {
final int j = random.nextInt(nums - i);
try {
String data1 = males.get(j);
System.out.println(Thread.currentThread().getName()
+ "正在把 ：'" + data1 + "'提出速配");
Thread.sleep((long) (Math.random() * 1000));

String data2 = exchanger.exchange(data1);
System.out.println(Thread.currentThread().getName()
+ "速配成功：'" + data1 + "'----" + "'" + data2+ "'");
males.remove(j);

} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
};
service.execute(r1);

Runnable r2 = new Runnable() {

@Override
public void run() {
// TODO Auto-generated method stub
for (int i = 0; i < nums; i++) {
final int j = random.nextInt(nums - i);
try {
String data1 = females.get(j);
System.out.println(Thread.currentThread().getName()
+ "正在把 ：'" + data1 + "'提出速配");
Thread.sleep((long) (Math.random() * 1000));

String data2 = exchanger.exchange(data1);
/*	System.out.println(Thread.currentThread().getName()
+ "速配成功：'" + data1 + "'----" + "'" + data2+ "'");*/
females.remove(j);

} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
};
service.execute(r2);

service.shutdown();
}
}