Java Exchanger并发类使用方法
简介
Exchanger是java 5引入的并发类，Exchanger顾名思义就是用来做交换的。这里主要是两个线程之间交换持有的对象。当Exchanger在一个线程中调用exchange方法之后，会等待另外的线程调用同样的exchange方法。
两个线程都调用exchange方法之后，传入的参数就会交换。
类定义
public class Exchanger<V>
其中V表示需要交换的对象类型。
类继承
java.lang.Object
↳ java.util.concurrent.Exchanger<V>
Exchanger直接继承自Object。
构造函数
Exchanger()
Exchanger提供一个无参构造函数。
两个主要方法
public V exchange(V x) throws InterruptedException
当这个方法被调用的时候，当前线程将会等待直到其他的线程调用同样的方法。当其他的线程调用exchange之后，当前线程将会继续执行。
在等待过程中，如果有其他的线程interrupt当前线程，则会抛出InterruptedException。
public V exchange(V x, long timeout, TimeUnit unit) throws InterruptedException, TimeoutException
和第一个方法类似，区别是多了一个timeout时间。如果在timeout时间之内没有其他线程调用exchange方法，则会抛出TimeoutException。
具体的例子
我们先定义一个带交换的类：
@Data
public class CustBook {
private String name;
}
然后定义两个Runnable，在run方法中调用exchange方法：
@Slf4j
public class ExchangerOne implements Runnable{
Exchanger<CustBook> ex;
ExchangerOne(Exchanger<CustBook> ex){
this.ex=ex;
}
@Override
public void run() {
CustBook custBook= new CustBook();
custBook.setName("book one");
try {
CustBook exhangeCustBook=ex.exchange(custBook);
log.info(exhangeCustBook.getName());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
@Slf4j
public class ExchangerTwo implements Runnable{
Exchanger<CustBook> ex;
ExchangerTwo(Exchanger<CustBook> ex){
this.ex=ex;
}
@Override
public void run() {
CustBook custBook= new CustBook();
custBook.setName("book two");
try {
CustBook exhangeCustBook=ex.exchange(custBook);
log.info(exhangeCustBook.getName());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
最后在主方法中调用：
public class ExchangerUsage {
public static void main(String[] args) {
Exchanger<CustBook> exchanger = new Exchanger<>();
// Starting two threads
new Thread(new ExchangerOne(exchanger)).start();
new Thread(new ExchangerTwo(exchanger)).start();
}
}
我们看下结果：
22:14:09.069 [Thread-1] INFO com.flydean.ExchangerTwo - book one
22:14:09.073 [Thread-0] INFO com.flydean.ExchangerOne - book two
可以看到对象已经被交换了。
结语
Exchanger在两个线程需要交换对象的时候非常好用。大家可以在实际工作生活中使用。
本文的例子https://github.com/ddean2009/learn-java-concurrency/tree/master/Exchanger
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了SpringMVC 单文件上传与多文件上传实例的相关资料,需要的朋友可以参考下2017-06-06
这篇文章主要为大家介绍了RocketMQ的push消费方式实现示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪<BR>2022-08-08
本篇文章主要介绍了springboot集成mqtt的实践开发，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-08-08
今天小编就为大家分享一篇springMVC中RestTemplate传值接值方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-08-08
提交gRPC-spring-boot-starter项目bug修复的pr说明
这篇文章主要介绍了这篇文章主要为大家介绍了gRPC-spring-boot-starter项目提交bug修复的pr的原因说明，有需要的朋友可以借鉴参考下，希望能够有所帮助2022-02-02
这篇文章主要为大家详细介绍了Java实现超市会员管理系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-03-03
这篇文章主要介绍了Java面试必备八股文整理,小伙伴们出去面试的时候会被问到很多java专业性的知识,那么八股文就是为此而出现的,需要的朋友可以参考下2023-03-03
这篇文章主要为大家详细介绍了Java代理模式的相关资料，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-03-03
SWT(JFace)体验之ApplicationWindow
SWT(JFace)体验之ApplicationWindow2009-06-06
Springboot调整接口响应返回时长详解(解决响应超时问题)
当后端对于数据量较大的处理或是某些耗时的操作时,需要先对请求接口的请求进行响应,下面这篇文章主要给大家介绍了关于Springboot调整接口响应返回时长(解决响应超时问题)的相关资料,需要的朋友可以参考下2023-01-01
最新评论