LinkedBlockingQueue thowing InterruptedException - PullRequest
Новая
       30

LinkedBlockingQueue thowing InterruptedException

0 голосов
/ 12 апреля 2011

У меня есть этот кусок кода. 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?
    }

}

1 Ответ

2 голосов
/ 12 апреля 2011

Если поток находится в состоянии прерывания, то есть Thread.interrupted () == true, то вызов вызовет InterruptionException.Это не обязательно означает, что поток был прерван, пока вы put ting, он мог уже быть в состоянии до входа.

...