Méthodes qui effacent le drapeau Thread.interrupt ()

J'ai récemment hérité d'une large Application Java qui n'a presque pas de Fil de sécurité. Ce que je suis en train de travailler sur l'obtention de tous les Threads pour gérer correctement d'être interrompu au lieu d'utiliser la très mauvaise Thread.stop().

Une partie du problème est que je ne sais pas à chaque appel de méthode qui efface le drapeau d'interruption.

Actuellement, je sais que la suite sera clairement l'interruption indicateur:

Thread.interrupted()
Thread.sleep(long)
Thread.join()
Thread.join(long)
Object.wait()
Object.wait(long)

Quoi d'autre ai-je raté? Merci

source d'informationauteur OverflowingStack

  1. 29

    Une partie du problème est que je ne sais pas à chaque appel de méthode qui efface le drapeau d'interruption.

    Il est important de préciser que les méthodes suivantes clair que l'interruption du pavillon simplement en les appelant:

    Thread.interrupted()
Thread.isInterrupted(true) -- added to your list

    Pour cette raison Thread.currentThread().isInterrupted() doit toujours être utilisée à la place.

    Les méthodes suivantes pour effacer l'interruption du pavillon par immédiatement jeter InterruptedException soit si ils ont été appelés et puis le thread a été interrompu ou si le thread a été déjà interrompue, et puis ils ont été appelés (voir junit code ci-dessous). Ce n'est pas la méthode qui efface le drapeau, en jetant l'exception ne.

    Thread.sleep(long)
Thread.sleep(long, int) – added to your list
Thread.join()
Thread.join(long)
Thread.join(int, long) – added to your list
Object.wait()
Object.wait(long)
Object.wait(int, long) – added to your list
BlockingQueue.put(...) – added to your list
BlockingQueue.offer(...) – added to your list
BlockingQueue.take(...) – added to your list
BlockingQueue.poll(...) – added to your list
Future.get(...) – added to your list
Process.waitFor() – added to your list
ExecutorService.invokeAll(...) – added to your list
ExecutorService.invokeAny(...) – added to your list
ExecutorService.awaitTermination(...) – added to your list
CompletionService.poll(...) – added to your list
CompletionService.take(...) – added to your list
CountDownLatch.await(...) – added to your list
CyclicBarrier.await(...) – added to your list
Semaphore.acquire(...) – added to your list
Semaphore.tryAcquire(...) – added to your list
Lock.lockInteruptibly() – added to your list
Lock.tryLock(...) – added to your list

    Veuillez noter que le bon modèle avec tout code qui attire InterruptedException est immédiatement re-interrompre le fil. Nous faisons cela dans le cas où d'autres s'appuient sur le thread.isInterrupted() méthode:

    try {
    ...
} catch (InterruptedException e) {
    //immediately re-interrupt the thread
    Thread.currentThread().interrupt();
    //log the exception or [likely] quit the thread
}

    JUnit code qui montre une partie de cette:

    assertFalse(Thread.currentThread().isInterrupted());
//you can do this from another thread by saying: someThread.interrupt();
Thread.currentThread().interrupt();
//this method does _not_ clear the interrupt flag
assertTrue(Thread.currentThread().isInterrupted());
//but this one _does_ and should probably not be used
assertTrue(Thread.interrupted());
assertFalse(Thread.currentThread().isInterrupted());
Thread.currentThread().interrupt();
assertTrue(Thread.currentThread().isInterrupted());
try {
    //this throws immediately because the thread is _already_ interrupted
    Thread.sleep(1);
    fail("will never get here");
} catch (InterruptedException e) {
    //and when the InterruptedException is throw, it clears the interrupt
    assertFalse(Thread.currentThread().isInterrupted());
    //we should re-interrupt the thread so other code can use interrupt status
    Thread.currentThread().interrupt();
}
assertTrue(Thread.currentThread().isInterrupted());
  2. 12

    Convention commune est la suivante: toute méthode qui jette InterruptedException (+ Thread.interrupted()) efface le drapeau d'interruption.

    Afin de faire de votre fils interruptable vous avez besoin de trouver tous les endroits où InterruptedException se fait prendre sans retrowing ou la restauration de l'interruption du pavillon. Depuis InterruptedException est un checked exception il n'est pas difficile à faire.

  3. 1

    Voici un SUPER FUN EXEMPLE:

    ch.la qualité de service.logback.de base.AsyncAppenderBase avant la version 1.1.4 les captures et les hirondelles InterruptedException sans réinitialisation de l'indicateur sur le fil.

    Donc, si vous utiliser quoi que ce soit sur les routes à cet enregistreur (comme slf4j), il en silence manger votre fil d'interruption d'état. Parce que, je veux dire, qui ne contrôle pas le fil d'interruption avant et après chaque opération de journal?