LinkedBlockingQueue thowing

Question

我有这段代码。LinkedBlockingQueue只有在等待添加到队列时被中断时才会抛出Exception。但是这个队列是无界的，所以它应该尽快添加。为什么我的shutdown方法抛出一个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时被中断了，它可能在进入之前就已经处于这个状态了。