回答情况：
提问时间：
问题标签：
如果我有bq1.drainTo(bq2)，其中bq1和bq2都是可从多个线程访问的BlockingQueue，我是否需要将排出与我必须对bq2进行的任何其他读/写操作同步？如果是这样的话，这似乎从一开始就消除了BlockingQueue的优势--有什么办法可以绕过它吗？若否，原因为何？如果有时，在什么情况下？
浏览 3提问于2015-03-20得票数 0
我知道blockingQueue可以用来触发这里的部分和ScheduledExecutorService，以固定的速度执行任务。但为了我的需要，我找不到把这两者联系起来的方法。
浏览 2提问于2016-08-21得票数 0
回答已采纳
有一种情况是，我希望在BlockingQueue上使用一种方法BlockingQueue。我把这个方法描述为
检索但不移除队列的头，必要时等待元素可用。在BlockingQueue，LinkedBlockingQueue上，我看不到相应的方法。这是存在的还是我可以这样做？
浏览 1修改于2011-07-25得票数 4
我目前正在阅读关于Java的文章，在许多网站上都给出了这个示例，以实现BlockingQueue的简单实现。代码很简单，但我有点困惑。例如，假设我们填充了队列，然后再尝试加入3次队列。public class BlockingQueue {
private int limit = 10;public BlockingQueue(int limit){ }
public synchronized
浏览 3修改于2020-08-07得票数 1
回答已采纳
编辑--我将BlockingQueue传递给一个执行器，我认为它使用的是add()方法，而不是BlockingQueue()。可以编写一个BlockingQueue，它包装另一个BlockingQueue并委托调用add()来提供()。
浏览 1修改于2009-08-05得票数 1
回答已采纳
有人知道为什么java的BlockingQueue没有putAll方法吗？这样的方法有问题吗？在不完全重新实现BlockingQueue的情况下，有什么好的方法可以解决这个问题吗？
浏览 14修改于2012-07-18得票数 6
BlockingQueue.put可以抛出InterruptedException。如何通过抛出此异常来导致队列中断？
浏览 0提问于2013-04-03得票数 3
回答已采纳
我刚刚开始了解如何使用BlockingQueue (数组或链接)，我想知道队列如何影响资源(CPU、内存等)？
从多大的角度来看，一个完整的队列开始成为服务器的问题(不是线程的数量，而是比例)？
浏览 1提问于2017-03-09得票数 1
回答已采纳
我正在尝试在我的代码中实现队列的使用。重点是我想让它打印出文件中的单词总数，这意味着我需要它在完成后将所有结果加在一起。public static void main(final String[] args) { if (args.length >= 1) {
String destin
浏览 0提问于2013-12-08得票数 0
下面是我的结果，这在(天真)测试中要快得多，而且我还没有遇到明显的线程问题(但是……(：) OPEN, CLOSED, ERROR; * Relies on the thread-safety of the used BlockingQueueprivate static final TimeUnit UNIT = TimeUnit.SECONDS;
private f
浏览 0提问于2012-11-09得票数 3
回答已采纳
298PipedStream.Produced 510BlockingQueue.Produced619BlockingQueue.Consume 584BlockingQueue.Produced327BlockingQueue
浏览 1修改于2019-07-16得票数 1
回答已采纳
BlockingQueue有一个名为drainTo()的方法，但它没有被阻塞。我需要一个我想阻塞的队列，并且能够在单个方法中检索排队的对象。Object first = blockingQueue.take();
blockingQueue.drainTo( list
浏览 6修改于2013-05-15得票数 34
回答已采纳
在无限循环中使用队列中的值时--哪个更有效：while (value = queue.take()) { doSomething(value); }while (true) {
}
浏览 2提问于2014-04-30得票数 36
回答已采纳
为什么ForkJoinPool没有像ThreadPoolExecutor这样的BlockingQueue？它似乎也没有拒绝队列。
浏览 0修改于2015-09-30得票数 0
在使用BlockingQueue时，我将以下逻辑实现为从它读取的，直到告诉其他。InterruptedException e) { }qIn (queue in)和qOut (queue )都声明为：private volatile BlockingQueue<String> qOut; <
浏览 0修改于2012-02-05得票数 0
回答已采纳
唯一的问题是，我不知道如何创建共享的BlockingQueue，树中的每个节点对象都可以将自己插入其中，以及如何创建一个由固定大小的线程组成的数组，不断等待队列中的新元素可用(然后执行它们)……直到将头从列表中删除我在网上搜索了BlockingQueue示例，但我只找到了生产者和消费者示例，而且我很难移动这些示例以适应我的问题。如果有人能帮我，我会很感激的。
浏览 0修改于2013-12-20得票数 1
回答已采纳
方法java.util.concurrent.BlockingQueue.add(E )的JavaDoc是：如果可以在不违反容量限制的情况下立即将指定的元素插入到此队列中，则在成功时返回
浏览 4提问于2010-11-12得票数 4
回答已采纳
我有以下blockingQueue；
final BlockingQueue<Message> blockingQueue = new LinkedBlockingQueue<Message>();如果不是，有什么可以替代BlockingQueue呢？
浏览 0提问于2012-03-20得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号