Java中的SynchronousQueue队列详解
简介
SynchronousQueue是BlockingQueue的一种，所以SynchronousQueue是线程安全的。
SynchronousQueue和其他的BlockingQueue不同的是SynchronousQueue的capacity是0。
即SynchronousQueue不存储任何元素。
也就是说SynchronousQueue的每一次insert操作，必须等待其他线性的remove操作。
而每一个remove操作也必须等待其他线程的insert操作。
这种特性可以让我们想起了Exchanger。和Exchanger不同的是，使用SynchronousQueue可以在两个线程中传递同一个对象。
一个线程放对象，另外一个线程取对象。
举例说明
我们举一个多线程中传递对象的例子。
还是举生产者消费者的例子，在生产者中我们创建一个对象，在消费者中我们取出这个对象。
先看一下用CountDownLatch该怎么做：
@Test
public void useCountdownLatch() throws InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(2);
AtomicReference<Object> atomicReference= new AtomicReference<>();
CountDownLatch countDownLatch = new CountDownLatch(1);
Runnable producer = () -> {
Object object=new Object();
atomicReference.set(object);
log.info("produced {}",object);
countDownLatch.countDown();
};
Runnable consumer = () -> {
try {
countDownLatch.await();
Object object = atomicReference.get();
log.info("consumed {}",object);
} catch (InterruptedException ex) {
log.error(ex.getMessage(),ex);
}
};
executor.submit(producer);
executor.submit(consumer);
executor.awaitTermination(50000, TimeUnit.MILLISECONDS);
executor.shutdown();
}
上例中，我们使用AtomicReference来存储要传递的对象，并且定义了一个型号量为1的CountDownLatch。
在producer中，我们存储对象，并且countDown。
在consumer中，我们await,然后取出对象。
输出结果：
[pool-1-thread-1] INFO com.flydean.SynchronousQueueUsage - produced java.lang.Object@683d1b4b
[pool-1-thread-2] INFO com.flydean.SynchronousQueueUsage - consumed java.lang.Object@683d1b4b
可以看到传入和输出了同一个对象。
上面的例子我们也可以用SynchronousQueue来改写：
@Test
public void useSynchronousQueue() throws InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(2);
SynchronousQueue<Object> synchronousQueue=new SynchronousQueue<>();
Runnable producer = () -> {
Object object=new Object();
try {
synchronousQueue.put(object);
} catch (InterruptedException ex) {
log.error(ex.getMessage(),ex);
}
log.info("produced {}",object);
};
Runnable consumer = () -> {
try {
Object object = synchronousQueue.take();
log.info("consumed {}",object);
} catch (InterruptedException ex) {
log.error(ex.getMessage(),ex);
}
};
executor.submit(producer);
executor.submit(consumer);
executor.awaitTermination(50000, TimeUnit.MILLISECONDS);
executor.shutdown();
}上面的例子中，如果我们使用synchronousQueue，则可以不用手动同步，也不需要额外的存储。
总结
如果我们需要在代码中用到这种线程中传递对象的情况，那么使用synchronousQueue吧。
到此这篇关于Java中的SynchronousQueue队列详解的文章就介绍到这了,更多相关SynchronousQueue队列内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
Springboot 在普通类型注入Service或mapper
这篇文章主要介绍了Springboot 在普通类型注入Service或mapper，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-11-11
springboot多数据源使用@Qualifier自动注入无效的解决
这篇文章主要介绍了springboot多数据源使用@Qualifier自动注入无效的解决，具有很好的参考价值，希望对大家有所帮助。也希望大家多多支持脚本之家2021-11-11
这篇文章主要介绍了SpringBoot Import及自定义装配实现方法解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-08-08
Spring Boot中的WebSocketMessageBrokerConfigurer接口使用
在SpringBoot中,我们可以使用 WebSocketMessageBrokerConfigurer接口来配置WebSocket消息代理,以实现实时通信,具有一定的参考价值,感兴趣的可以了解一下2023-11-11
通过源码分析，我们可以更深入的了解其底层原理。本文将通过Timer的源码，带大家深入了解Java Timer的使用，感兴趣的小伙伴可以了解一下2022-11-11
详解Java的Hibernate框架中的Interceptor和Collection
这篇文章主要介绍了Java的Hibernate框架中的Interceptor和Collection,Hibernate是Java的SSH三大web开发框架之一,需要的朋友可以参考下2016-01-01
这篇文章主要介绍了Spring面试资料，学Java的小伙伴都知道Spring是面试的必问环节，看完了一天就可掌握数据结构和算法的面试题，快来看看吧2021-08-08
本篇文章主要介绍了详解Spring Aop实例之xml配置，使用xml可以对aop进行集中配置，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-04-04
动态 SQL 是 MyBatis 的强大特性之一。如果你使用过 JDBC 或其它类似的框架，你应该能理解根据不同条件拼接 SQL 语句有多痛苦，例如拼接时要确保不能忘记添加必要的空格，还要注意去掉列表最后一个列名的逗号。利用动态 SQL，可以彻底摆脱这种痛苦2022-04-04
本文主要介绍了SpringBoot实现redis缓存菜单列表，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2022-01-01
最新评论