Java多线程与并发库高级应用之线程数据交换Exchanger

JDK1.5提供了Exchanger用于两个线程的数据交换。两个线程先后到达交换点，先到达的线程会等待后到达的线程，然后两个线程互相交换数据，交换后双方持对方的数据。

Exchanger只提供了一个构造器：

Exchanger()：创建一个新的Exchanger。

Exchanger中也只有两个方法：

V exchange(V
x)： 等待另一个线程到达此交换点（除非当前线程被中断），然后将给定的对象传送给该线程，并接收该线程的对象。

V
exchange(V x, long timeout, TimeUnit unit)： 等待另一个线程到达此交换点（除非当前线程被中断，或者超出了指定的等待时间），然后将给定的对象传送给该线程，同时接收该线程的对象。

见下面程序

[java] view plaincopy

1. public class ExchangerDemo {
2. public static void main(String[] args) {
3. //线程池


4. ExecutorService pool = Executors.newCachedThreadPool();


5. //Exchanger


6. final Exchanger<String> changer = new Exchanger<String>();
7. //用于交互数据的线程1


8. pool.execute(new Runnable() {
9. @Override


10. public void run() {


11. try{


12. String data1 = "苹果";


13. System.out.println(Thread.currentThread().getName() +


14. "-准备交换数据：" + data1);


15. Thread.sleep((long)(Math.random()*10000));


16. String data2 = (String)changer.exchange(data1);


17. System.out.println(Thread.currentThread().getName() +


18. "-已交换完数据，交换到的数据：" + data1);


19. }catch(InterruptedException e){


20. e.printStackTrace();


21. }


22. }


23. });
24. //用于交互数据的线程2


25. pool.execute(new Runnable() {
26. @Override


27. public void run() {


28. try{


29. String data1 = "石榴";


30. System.out.println(Thread.currentThread().getName() +


31. "-准备交换数据：" + data1);


32. Thread.sleep((long)(Math.random()*10000));


33. String data2 = (String)changer.exchange(data1);


34. System.out.println(Thread.currentThread().getName() +


35. "-已交换完数据，交换到的数据：" + data1);


36. }catch(InterruptedException e){


37. e.printStackTrace();


38. }


39. }


40. });
41. pool.shutdown();


42. }


43. }

看到两个线程将数据彼此交换。

Java多线程与并发库高级应用之线程数据交换Exchanger,码迷,mamicode.com