Wie Schreibe ich einen JUnit-Testfall zu testen, threads und events

Müssen Sie möglicherweise neu zu strukturieren Sie Ihren code so, dass es leicht sein kann, getestet.

Ich kann sehen, dass Sie verschiedene Bereiche für die Prüfung:

1. Thread-Management-code: der code, der startet den thread(s) und vielleicht wartet auf die Ergebnisse
2. Die "Arbeiter" - Ausführung von code in den thread
3. Die concurrency-Probleme, die auftreten, wenn mehrere threads aktiv sind

Struktur Ihrer Implementierung, so dass eine Thread-Management-code ist agnostisch in Bezug auf die Modalitäten der Arbeiter. Dann können Sie mit Gespielter Arbeitnehmer zu ermöglichen das testen von Thread-Management - zum Beispiel ein Mock-Arbeiter, der scheitert in gewisser Weise können Sie testen, bestimmte Pfade in der management-code.

Implementieren der Arbeiter-code, so dass es sein kann, die isoliert ausgeführt werden. Sie können dann unit-Tests unabhängig voneinander, mit mocks für den server.

Für die Parallelität Prüfung der links, die von Abhijeet Kashnia helfen.

Ich schlage vor, Sie verwenden ein mocking-framework, um zu bestätigen, dass die server-Aufruf wurde in der Tat gemacht. Wie für die thread unit-Tests: Unit-Tests Multithread-Anwendungen

Ich vermute, dass Sie möglicherweise getan haben, Ihre Spott-code und möchten eine einfache integration test, um sicherzustellen, dass Ihre server-Aufruf funktioniert.

Eines der Probleme, die in die Prüfung von Gewinde kommt aus Ihrer Natur - Sie sind gleichzeitige. Das bedeutet, dass man Kraft in das schreiben von JUnit-test-code, der gezwungen ist, zu warten, bis der thread beendet hat, seinen job vor dem testen Sie Ihren code-Ergebnisse. Dies ist nicht eine sehr gute Art, testen von code, und kann unzuverlässig sein, aber in der Regel bedeutet, dass Sie eine Idee haben, ob Ihr code funktioniert.

Als ein Beispiel, kann Ihr code so Aussehen:

@Test
public void myIntegrationTest() throws Exception {

   //Setup your test


   //call your threading code
   Results result = myServerClient.doThreadedCode();

   //Wait for your code to complete
   sleep(5);

   //Test the results
   assertEquals("some value",result.getSomeValue());

}


private void sleep(int seconds) {

    try {
        TimeUnit.SECONDS.sleep(seconds);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}

Ich weiß wirklich nicht, wie dies zu tun und lieber verspottet und Stimme mit den anderen Antworten. Aber, wenn Sie brauchen, um zu testen, Ihre threads, dann ist dies ein Ansatz, den ich finde funktioniert.

Wenn Ihr problem ist nur warten auf das Ergebnis, verwenden Sie ExecutorService zum laichen Ihre threads. Kann es akzeptieren, Arbeit, Arbeitsplätze, sowohl als Runnable und Callable. Wenn Sie das letztere, dann erhalten Sie eine Zukunft - Objekt zurück, das verwendet werden kann, um auf das Ergebnis zu warten. Sollten Sie ExecutorService jedenfalls, als aus dem, was ich verstehe, Sie erstellen viele threads, und dies ist ein perfekter Anwendungsfall für Testamentsvollstrecker Dienstleistungen.

class AnyClass {
    private ExecutorService threadPool = Executors.newFixedThreadPool(5);

    public List<Future<Integer>> anyMethod() {
        List<Future> futures = new ArrayList<>();

        futures.add(threadPool.submit(() -> {
            //Do your job here
            return anyStatusCode;
        }));

        futures.add(threadPool.submit(() -> {
            //Do your other job here
            return anyStatusCode;
        }));

        return futures;
    }
}

Und die test-Klasse:

class TestAnyClass {
    @Test
    public void testAnyMethod() {
        AnyClass anyObject = new AnyClass();

        List<Future<Integer>> futures = anyObject.anyMethod();
        CompletableFuture[] completable = futures.toArray(new CompletableFuture[futures.size()]);

        //Wait for all
        CompletableFuture.allOf(completable).join();
    }
}