Это прерывание() необходимо?

Question

Вот фрагмент кода:

public class LogService { 

    public void stop() { 
     synchronized (this) { isShutdown = true; } 
     loggerThread.interrupt(); /* Is it necesarry? */ 
    } 

    public void log(String msg) throws InterruptedException { 
     synchronized (this) { 
      if (isShutdown) 
      throw new IllegalStateException(...); 
      ++reservations; 
     } 
     queue.put(msg); 
    } 

    private class LoggerThread extends Thread { 
     public void run() { 
      try { 
       while (true) { 
        try { 
         synchronized (LogService.this) { 
          if (isShutdown && reservations == 0) 
           break; 
         } 
         String msg = queue.take(); 
         synchronized (LogService.this) { 
         --reservations; 
         } 
         writer.println(msg); 
        } catch (InterruptedException e) { } /* Do nothing */ 
       } 
      } finally { 
       writer.close(); 
      } 
     } 
    } 
} 

В приведенном выше коде, даже если положить LoggerThread.interrupt() в остановке() метод, прерывание просто быть пойманной нить и ничего не делать.

Значит, LoggerThread.interrupt() необходимо?

Answer 1

Да, это необходимо. Если очередь пуста, это заявление String msg = queue.take(); будет блокироваться до тех пор, пока элемент не будет помещен в очередь или он не будет прерван.

Если вы хотите гарантировать, что нить не зависает, вам необходимо ее прервать.

Однако, похоже, глюк: если reservations не 0 при вызове метода close И очередь пуста, то кажется, что ваш цикл будет продолжать идти и повесить на queue.take() на время цикла итерации после перерыва.