BlockingQueue的InterruptedException如何处理？ [复制]答案

【问题标题】：How to handle InterruptedException of BlockingQueue? [duplicate]BlockingQueue的InterruptedException如何处理？ [复制]
【发布时间】：2016-07-28 03:35:42
【问题描述】：

我有一个与此类似的代码，它位于 Runnable 的 run() 方法中，并启动了该 Runnable 的多个实例，

do{
        try{
            String contractNum=contractNums.take();
           }catch(InterruptedException e){
            logger.error(e.getMessage(), e);
        }
  }while(!("*".equals(contractNum)));

其中contractNums 是由多个线程共享的BlockingQueue<String>。有单独的Runnables 将元素放入此队列。

我不确定捕获InterruptedException 后的下一步，我应该通过重新抛出RuntimeException 来终止这个线程（所以我的while 循环终止）还是尝试再次从contractNum queue 中获取下一个元素并忽略InterruptedException?

我不确定InterruptedException 是否被视为线程终止或将其保持在while 循环中的致命条件。

请提出建议。

【问题讨论】：

标签： java multithreading concurrency blockingqueue

【解决方案1】：

这取决于。是否有故意中断线程的地方，例如告诉它完成（例如在关闭期间）？如果没有，您只需要处理可能会唤醒线程的虚假中断。如果您不希望处理受到影响，请忽略它们。它们绝对不是致命异常，您不需要记录它们（尤其是作为错误）。

【讨论】：

谢谢。不，没有故意中断。
那么你就不需要对他们采取任何特殊的行动了。

【解决方案2】：

7.1.2 中断政策

就像任务应该有取消政策一样，线程也应该有中断政策。中断策略决定线程如何解释一个中断请求——当一个中断请求时它做什么（如果有的话）检测到，哪些工作单元被认为是原子的中断，以及它对中断的反应速度。最多明智的中断策略是某种形式的线程级或服务关卡取消：尽可能快地退出，如果必要的，并可能通知某个拥有实体该线程正在退出。可以建立其他中断策略，例如暂停或恢复服务，但线程或线程池非标准中断策略可能需要限制为在了解政策的情况下编写的任务。

7.1.3 应对中断

如前所述，当您调用可中断的阻塞方法时比如 Thread.sleep 或者 BlockingQueue.put ，有两个实用的处理 InterruptedException 的策略：

• 传播异常（可能在某些特定于任务的清理之后），使您的方法也成为可中断的阻塞方法；或

• 恢复中断状态，以便代码在调用上更高堆栈可以处理它。

Java Concurrency in Practice第七章。

特别是在您的代码中，您需要确保如果线程被中断，您的应用程序逻辑不会被破坏。捕获您的中断异常确实更好。如何处理它取决于您，只需尝试确保您不会破坏应用程序逻辑。

【讨论】：

感谢您引用该书。在第 143 - 144 页上，描述了我的场景，并建议我只需要在线程即将完成时在外部 finally 块中调用 Thread.currentThread.interrupt() 一次 - 无论抛出此异常的次数如何。在内部捕获中，我应该忽略异常并重试队列中的take() 元素。