0

私はこのコードを持っています。Aは、キューへの追加を待機しているときに中断された場合に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?
    }

}
4

1 に答える 1

2

スレッドが中断状態にある場合、つまり Thread.interrupted() == true の場合、呼び出しはInterruptionException. 途中でスレッドが中断したとは限らずput、入る前の状態だった可能性もあります。

于 2011-04-12T13:29:16.360 に答える