Exchanger这个类用于交换数据，只能用于两个线程 。当一个线程运行到 exchange() 方法时会阻塞，另一个线程运行到 exchange() 时，两者交换数据，然后执行后面的程序 。
package test;import java.util.concurrent.Exchanger;public class Test3 { static class Producer extends Thread{ // 生产者线程 private Exchanger<Integer> exchanger; // 交换标志 private static int data = 0; Producer(String name, Exchanger<Integer> exchanger){ super("Producer-" + name); this.exchanger = exchanger; } @Override public void run(){ for (int i = 1; i < 5; i++) { try { Thread.sleep(1000); data = i; System.out.println(getName() + "交换前：" + data); data = exchanger.exchange(data); // 将此 data 与 消费者的 data 进行交换 System.out.println(getName() + "交换后：" + data); }catch (InterruptedException e){ e.printStackTrace(); } } } } static class Consumer extends Thread{ // 消费者线程 private Exchanger<Integer> exchanger; // 交换标志 private static int data = 0; Consumer(String name, Exchanger<Integer> exchanger){ super("Consumer-" + name); this.exchanger = exchanger; } @Override public void run(){ while(true){ data = 0; System.out.println(getName() + "交换前：" + data); try{ data = exchanger.exchange(data); // 将此 data 与生产者的 data 进行交换，因为先执行到这，会阻塞知道生产者执行到交换 }catch (InterruptedException e){ e.printStackTrace(); } System.out.println(getName() + "交换后：" + data); } } } public static void main(String[] args) throws InterruptedException { Exchanger<Integer> exchanger = new Exchanger<>(); new Producer("", exchanger).start(); new Consumer("", exchanger).start(); Thread.sleep(7000); }}
推荐阅读
![[快科技]小米10青春版邀请函图赏：哆啦A梦迷你抓娃娃机](http://ttbs.guangsuss.com/image/3edcbb553cbab8a02c1d1c782772809f)
- 菊花茶的好处,菊花茶有哪些好处
- 水鬼是什么样的 水鬼长啥样真实的
- PS制作出有纹理的背景素材
- 古代最常用的兵器 中国古代有名的兵器
- 这9个程序员工具网站，太牛了吧
- 常喝人参泡水的好处,人参泡水的大好处
- 百香果花茶的做法,百香果茶的做法种常见百香果饮品做法
- 男生粘人的心理原因是什么？
- 蛋皮经常痒是怎么回事？
- 常喝杨梅酒好处和坏处 喝杨梅酒好吗