Nitka zachowuje się dziwnie w JUnit

Question

Próbuję napisać test jednostkowy, który wymaga wielu wątków. Wydaje się jednak, że wątki po prostu przerywają częściowe wykonywanie. Rozważmy następujący kod:

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

Jeśli uruchomić ten test jednostki, to zazwyczaj zatrzymać wyświetlanie wyjścia gdzieś pomiędzy 140-180. Jeśli skonwertuję ten kod na zwykłą klasę i uruchomię go, działa dobrze. Czy ktoś ma pojęcie, czego tu brakuje?

Dzięki, - Andrew.

Answer 1

Prawdopodobnie kończy się wątek rodzica uruchamiający test. Jeśli możesz tego uniknąć, nie twórz nowego wątku w testach. Utworzyłem nową klasę implementującą działające, a następnie przetestowałem tę klasę, moje proste wywoływanie uruchomione na tym obiekcie. Nie powinieneś testować planowania wątków jako części twoich testów. Mam nadzieję, że zespół programistów języka Java ma to pokryte:

Answer 2

W funkcji TestThread JUnit nie ma możliwości poinformowania, że ​​utworzono nowy wątek. Odzyskuje wszelkie obiekty, które utworzył w funkcji, gdy tylko funkcja się zakończy (ostatni wiersz zostanie osiągnięty) i nie wie nic o wątku.

Z tego powodu widzisz Wynik z wątku, dopóki nie zostanie zabity. Jeśli chcesz poczekać na ukończenie wątku, możesz użyć Thread.join (zaraz po wywołaniu Thread.start()), aby poczekać na wynik lub użyć wait-notify dla jakiegoś obiektu.

również znaleźć na to pytanie: JUnit terminates child threads

Answer 3

Można użyć Thread.join() aby zapobiec test z wykańczania zanim nowy wątek zakończył zadanie:

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

Normalnie JVM wygasa, gdy ostatni wątek nie będący demonem kończy się. Można się spodziewać, że po prostu wywołanie t.setDaemon(false) w wątku uniemożliwi maszynie JVM wyjście z tego zadania. Jednak junit będzie call System.exit(), gdy główny wątek został zakończony.

Jak zauważa Gus w komentarzach: "potrzebujesz join(), ponieważ start() nie blokuje".

Ma rację, że można również zadzwonić pod numer run() w tym minimalnym przykładzie. Zakładam jednak, że zaczynasz wątek, ponieważ chcesz, aby działał równolegle z innym wątkiem. Wywołanie run() na wątku jest oznaczane jako ewentualny błąd przez FindBugs - jeśli chcesz tylko zadzwonić pod numer run(), prawdopodobnie chcesz zaimplementować Runnable zamiast używać Thread.