Java并发编程核心方法与框架-exchanger的使用
2024-03-24 22:59:04
Exchanger可以使两个线程之间传输数据，比生产者/消费者模式使用wait/notify更加方便。
Exchanger中的exchange()方法具有阻塞的特点，此方法被调用后等待其他线程来取数据，如果没有其他线程取得数据，则一直阻塞等待。
public class ThreadA extends Thread {
private Exchanger<String> exchanger;
public ThreadA(Exchanger<String> exchanger) {
super();
this.exchanger = exchanger;
}
@Override
public void run() {
try {
System.out.println("A线程获得的值：" + exchanger.exchange("String from threadA"));
System.out.println("threadA end");
} catch (Exception e) {
e.printStackTrace();
}
}
}
public class ThreadB extends Thread {
private Exchanger<String> exchanger;
public ThreadB(Exchanger<String> exchanger) {
super();
this.exchanger = exchanger;
}
@Override
public void run() {
try {
System.out.println("B线程获得的值：" + exchanger.exchange("String from threadB"));
System.out.println("threadB end");
} catch (Exception e) {
e.printStackTrace();
}
}
}
public class Main {
public static void main(String[] args) {
Exchanger<String> exchanger = new Exchanger<>();
ThreadA a = new ThreadA(exchanger);
a.setName("A");
ThreadB b = new ThreadB(exchanger);
b.setName("B");
a.start();
b.start();
System.out.println("main end");
}
}
运行程序，控制台打印结果如下：
main end
A线程获得的值：String from threadB
threadA end
B线程获得的值：String from threadA
threadB end
最新文章
- 推荐几篇关于EF的好文章
- Windows API Hooking in Python
- Java借助axis2发布WebService
- Java8简单的本地缓存实现
- Redis的五种数据结构
- 关于Youtube URL的十个技巧
- C语言使用宏实现２个变量的交换
- app整体搭建环境：tabBar切换不同控制器的封装（自定义导航+自定义uiviewcontroler+系统自带tabbar+自定义tabbarController）
- FileHelper-文件操作辅助类
- poj 2635 千进制
- mysql max_allowed_packet错误
- Mod 与 RequireJS/SeaJS 的那些事
- 哈夫曼(Huffman)编码
- Linux操作系统
- InnoDB引擎数据存放位置
- jQuery实现 图片的局部放大效果
- 在Windows上安装Arduino-IDE
- ambari卸载集群
- Spring IOC（八）bean 的创建
- Hadoop生态圈-Kafka的本地模式部署