java - LinkedBlockingQueue 抛出 InterruptedException

Question

我有这段代码。如果在等待添加到队列时被中断，LinkedBlockingQueue 应该仅抛出 Exception。但这个队列是无限的，所以它应该尽快添加。为什么我的关闭方法会抛出 InterruptedException？

private final LinkedBlockingQueue<Message> messages= new LinkedBlockingQueue<Message>();

public void run(){
    LinkedList<Message> messages = new LinkedList<Message>(); 
    while (true){
        try{
            messages.clear();
            messages.add(this.messages.take());
                            this.messages.drainTo(messages);
            for (Message message:messages){
                if(message.isPoison())return;
                doSomething(message);
            }
        }catch(Exception e){
            getLogger().addException(e);
        }
    }
}


protected void add(Message m){
    try {
        messages.put(m);
    }catch (InterruptedException e) {
        getLogger().addException(e);
        addRollback(e);
    }
}

public void shutdown(){
    try{
        messages.put(MessageFactory.getPoison());
    }catch(InterruptedException e){
     //here an exception is thrown. Why?
    }

}

Answer 1

如果线程处于中断状态，即Thread.interrupted() == true，则调用将抛出InterruptionException。这并不一定意味着线程在您put时被中断，它可能已经处于进入之前的状态。