BlockingDeque не разблокируется после того, как элемент вставлен в очередь

Question

Я в затруднении. У меня есть BlockingDeque

private class Consumer extends Thread { 

    @Override 
    public void run() { 
     try { 
      while (!Thread.currentThread().isInterrupted()) { 
       if (connection.isReady()) { 
        final Item item = queue.takeFirst(); 
        try { 
         ListenableFuture<Result> listenableFuture = connection.submitItem(item); 
         Futures.addCallback(listenableFuture, new FutureCallBackImpl<Result>(item)); 
        } catch (RejectedExecutionException e) { 
         LOGGER.debug("Slow down submission of tasks we have a queue full in connection"); 
         queue.addFirst(item); 

        } 
       } 
      } 
     } catch (InterruptedException e) { 
      LOGGER.debug("Interrupted. I will not propagate up because I own this thread"); 

     } 
    } 
} 

Этот код обычно блокируется на queue.takeFirst() когда никакие пункты не находятся в очереди. Тем не менее, он не разблокируется, как только я добавляю элемент, как ожидалось. Во время отладки я вижу элементы, находящиеся в queue, а также когда я останавливаю Tomcat I, сериализую queue. После запуска я де-сериализую очередь, и в этот момент queue.takeFirst() извлекает элемент (тот же, который ранее не извлекал), и отправляет его.

У кого-нибудь есть идеи?

EDIT

Чтобы подчеркнуть свою точку немного больше. Если я изменил queue.takeFirst() на queue.pollFirst() и немного изменил код, чтобы игнорировать проходы, которые дают nullitems, тогда код работает так, как ожидалось.

Answer 1

Возможно, ваш код не вводит if, потому что connection.isReady() возвращает false.

Проверьте его, чтобы он действительно прекратил ждать первого элемента в очереди.

Answer 2

Итак, позвольте мне объяснить, почему этот кусок кода не будет работать, когда элементы добавляются в очередь в следующий раз (то есть после того, как из очереди все элементы первого)

Когда очередь пустеет в первый раз, вызов этого кода final Item item = queue.takeFirst(); будет вызывать InterruptedException, который попадает в код за пределами цикла while, поэтому код больше никогда не вернется к циклу while. Вставка первой попытки блокировки внутри цикла будет решить первую проблему.

Во-вторых, ему нужно было позвонить Thread.currentThread().interrupted() внутри блока catch, чтобы в следующий раз передать условие while, чтобы он был готов читать для добавления будущих элементов в очередь. Infact Я не понял причины для вызова этой строки кода while (!Thread.currentThread().isInterrupted()).

В настоящее время я пишу интересный блог для BlockingDeque (WIP), в скором времени вы найдете более подробную информацию в своем блоге http://singletonjava.blogspot.com