在项目插入队列后，BlockingDeque不会解除阻止

Question

我不知所措。我有一个阻塞请求

private class Consumer extends Thread {

    @Override
    public void run() {
        try {
            while (!Thread.currentThread().isInterrupted()) {
                if (connection.isReady()) {
                    final Item item = queue.takeFirst();
                    try {
                        ListenableFuture<Result> listenableFuture = connection.submitItem(item);
                        Futures.addCallback(listenableFuture, new FutureCallBackImpl<Result>(item));
                    } catch (RejectedExecutionException e) {
                        LOGGER.debug("Slow down submission of tasks we have a queue full in connection");
                        queue.addFirst(item);

                    }
                }
            }
        } catch (InterruptedException e) {
            LOGGER.debug("Interrupted. I will not propagate up because I own this thread");

        }
    }
}

此代码通常会阻塞＜code＞队列。takeFirst（）当队列中没有项目时。但是，一旦我按预期添加了项目，它就不会解除阻止。调试时，我可以看到队列中的项目，并且当我停止Tomcat时，我会序列化队列。启动后，我将对队列进行反序列化，并在那一点上对＜code＞队列进行反串行化。takeFirst（）检索项目（与之前未检索的相同）并提交它。

有人有什么想法吗？

编辑

再强调一下我的观点。如果我使用 queue.pollFirst（） 更改 queue.takeFirst（） 并稍微调整代码以忽略产生空项的传递，那么代码将按预期工作。

Answer 1

所以让我解释一下为什么下次将项目添加到队列时（即在它首先将所有元素出列之后）这段代码将不起作用

当队列第一次变空时，对这段代码的调用最终项目=queue.take第一（）；将抛出中断异常，该异常被同时循环外部的代码捕获，因此代码将永远不会再次返回到同时循环。将第一个尝试块放在同时循环中将解决第一个问题。

其次，它需要调用Thread.currentThread（）。中断（）在捕捉块中传递下一次的同时条件，以便它准备好读取将来添加到队列中的元素。事实上，我不明白调用这一行代码的原因。Thread.current线程（）。is中断（））。

目前我正在为BlockingDeque（进展中）写有趣的博客，很快你会在我的博客上找到更多信息http://singletonjava.blogspot.com

Answer 2

也许你的代码没有输入if，因为connection.isReady（）返回false。

检查它以确保它确实停止等待队列中的第一项。