Thread verhält sich seltsam in JUnit

Question

Ich versuche, einen Komponententest zu schreiben, der mehrere Threads erfordert. Es scheint jedoch, dass die Threads nur einen Teil der Ausführung stoppen. Betrachten Sie den folgenden Code ein:

public class Test { 
    @org.junit.Test 
    public void TestThreads() { 
     new Thread(new Runnable() { 
      public void run() { 
       for (int i = 1; i < 1000; i++) System.out.println(i); 
      } 
     }).start(); 
    } 
} 

Wenn ich diesen Unit-Test ausführen, wird es in der Regel stoppen Ausgabe irgendwo zwischen 140-180 anzeigt. Wenn ich diesen Code in eine reguläre Klasse umwandeln und ausführen, funktioniert es einwandfrei. Hat jemand eine Idee, was ich hier vermisse?

Danke, - Andrew.

Answer 1

Es ist wahrscheinlich, dass der übergeordnete Thread, der den Test ausführt, beendet wird. Wenn Sie es vermeiden können, dann erstellen Sie keinen neuen Thread in Ihren Tests. Ich würde eine neue Klasse erstellen, die das Runnable implementiert, und dann diese Klasse testen, indem ich einfach auf dieses Objekt rufe. Sie sollten die Thread-Planung nicht als Teil Ihrer Tests testen müssen. Hoffentlich hat das Java-Sprachentwickler-Team das abgedeckt :)

Answer 2

In der TestThread-Funktion kann JUnit nicht sagen, dass Sie einen neuen Thread erstellt haben. Sie ruft alle Objekte zurück, die sie in der Funktion erstellt hat, sobald die Funktion endet (die letzte Zeile ist erreicht) und nichts über den Thread weiß.

Aus diesem Grund sehen Sie Ausgabe vom Thread, bis es getötet wird. Wenn Sie auf Thread Completion warten möchten, können Sie Thread.join verwenden (direkt nach dem Aufruf Thread.start()), um es auf das Ergebnis warten oder wait-notify für ein Objekt verwenden.

auch gefunden, diese Frage: JUnit terminates child threads

Answer 3

Sie können Thread.join() verwenden Sie den Test aus dem Finish zu verhindern, bevor der neue Thread seine Aufgabe erfüllt hat:

@org.junit.Test 
public void TestThreads() throws InterruptedException { 
    Thread t = new Thread(new Runnable() { 
     public void run() { 
      for (int i = 1; i < 1000; i++) System.out.println(i); 
     } 
    }); 
    t.start(); 
    t.join(); 
} 

Normalerweise wird die JVM beendet, wenn die letzte Nicht-Daemon-Thread wird beendet. Sie könnten erwarten, dass das Aufrufen von t.setDaemon(false) für den Thread verhindern würde, dass die JVM beendet wird, bevor die Aufgabe abgeschlossen ist. junit wird jedoch call System.exit(), wenn der Haupt-Thread beendet ist.

Wie Gus in den Kommentaren festhält: "Sie brauchen join() weil start() nicht blockiert".

Er ist richtig, dass Sie run() in diesem minimalen Beispiel auch aufrufen können. Ich nehme jedoch an, dass Sie einen Thread starten, weil Sie möchten, dass er gleichzeitig mit einem anderen Thread ausgeführt wird. Der Aufruf von run() auf einem Thread wird von FindBugs als möglicher Fehler gemeldet - wenn Sie nur run() aufrufen, möchten Sie wahrscheinlich nur Runnable implementieren, anstatt Thread zu verwenden.