LinkedBlockingQueue 的插入和删除方法线程安全吗？

发布于 2024-08-30 03:24:08 字数 229 浏览 2 评论 0原文

我在两个不同的线程之间使用 LinkedBlockingQueue 。一个线程通过 add 添加数据，而另一个线程通过 take 接收数据。

我的问题是，我是否需要同步对 add 和 take 的访问。 LinkedBlockingQueue 的插入和删除方法线程安全吗？

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

枯叶蝶 2024-09-06 03:24:08

是的。来自文档：

“BlockingQueue 实现是
线程安全。所有排队方式
使用原子方式实现其效果
内部锁或其他形式的
并发控制。然而，大部分
集合操作addAll，
containsAll、retainAll 和 removeAll
不一定执行
除非另有说明，否则以原子方式
在一个实现中。原来如此
可能，例如，对于 addAll(c)
之后失败（抛出异常）
仅添加其中的一些元素
c.”

编辑： addAll 行为不是多线程特定的问题，因为单线程场景可能有完全相同的问题。

在单线程应用程序中，创建一个 ArrayList list 最后有 9 个非空元素和 1 个空元素

调用 queue.addAll(list);

假设它按顺序添加元素（我不相信这是保证的）），它会添加前 9 个，然后抛出异常（BlockingQueue 不允许 null 元素。） 9 仍然会被添加到队列中。

但很可能会原子要求很多，集合是否是线程安全的，它需要对整个集合进行快照然后回滚是的，它可以针对许多集合实现（尽管对于某些集合来说会很复杂），但我不会。假设任何集合（无论是否是线程安全的）都这样做。

底线：集合很复杂，并且它们的保证各不相同，查阅文档很重要。
线程安全只是许多人关心的问题之一。

回复收藏 0 原文

坐在坟头思考人生 2024-09-06 03:24:08

是的，BlockingQueue 方法 add() 和 take() 是线程安全的但有区别。

add () 和 take() 方法使用 2 个不同的 ReentrantLock 对象。

add() 方法使用

private final ReentrantLock putLock = new ReentrantLock();

take() 方法使用

private final ReentrantLock takeLock = new ReentrantLock();

因此，对 add() 方法的同时访问是同步的。同样，同时访问 take() 方法也是synchronized。

但是，同时访问 add() 和 take() 方法不是同步，因为它们使用 2 个不同的锁对象（除了在队列满/空的边缘条件期间）。

Yes, BlockingQueue methods add() and take() are thread safe but with a difference.

add () and take() method uses 2 different ReentrantLock objects.

add() method uses

private final ReentrantLock putLock = new ReentrantLock();

take() method uses

private final ReentrantLock takeLock = new ReentrantLock();

Hence, simultaneous access to add() method is synchronized. Similarly, simultaneous access to take() method is synchronized.

But, simultaneous access to add() and take() method is not synchronized since they are using 2 different lock objects (except during edge condition of queue full / empty).

回复收藏 0 原文