È necessario questo interrupt()?

Question

Ecco il frammento di codice:

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(); 
      } 
     } 
    } 
} 

Come il codice di cui sopra, anche se mettiamo LoggerThread.interrupt() nel metodo stop(), l'interruzione solo essere catturato da filo e non fare nulla.

Quindi è LoggerThread.interrupt() necessario?

Answer 1

Sì, è necessario. Se la coda è vuota, questa istruzione String msg = queue.take(); verrà bloccata fino a quando un elemento non viene inserito nella coda o viene interrotto.

Se si desidera garantire che il thread non si blocchi, è necessario interromperlo.

Tuttavia sembra che ci sia un problema tecnico: se reservations non è 0 quando si chiama il metodo close e la coda è vuota, sembra che il ciclo andrà avanti e appendere queue.take() al ciclo while di iterazione dopo l'interruzione.