Wie kann sichergestellt werden, dass alle Java-Threads abgeschlossen sind, bevor fortgefahren wird?

So warten Sie, bis alle Threads ihre Arbeit in Java abgeschlossen haben

Wenn Sie mit mehreren Threads arbeiten, ist es wichtig, deren Ausführung zu koordinieren und sicherzustellen, dass sie ihre Aufgaben abschließen, bevor Sie fortfahren. In diesem Szenario haben Sie fünf Threads, die gleichzeitig Daten aus dem Web abrufen und eine Pufferklasse füllen. Ihr Ziel ist es, die Daten im Puffer zu validieren und sie erst dann in einer Datenbank zu speichern, wenn alle Threads ihre Arbeit abgeschlossen haben.

Lösung von ExecutorService

Eine effektive Möglichkeit, dies in Java zu erreichen, ist Nutzung des ExecutorService, der eine praktische API zum Verwalten von Thread-Pools bereitstellt. So können Sie diesen Ansatz umsetzen:

ExecutorService es = Executors.newCachedThreadPool();

// Submit the tasks to the executor service
for (int i = 0; i < 5; i++) {
    es.execute(new Runnable() {
        // Implement your task here
    });
}

// Shut down the executor service after submitting the tasks
es.shutdown();

// Wait for all tasks to finish or for a specified timeout
boolean finished = es.awaitTermination(1, TimeUnit.MINUTES);

// If all tasks have finished, proceed with validation and database storage
if (finished) {
    validateBufferData();
    storeDataInDatabase();
}

Durch die Verwendung der Methode „awaitTermination“ können Sie den Hauptthread blockieren, bis alle Aufgaben im Executor-Dienst abgeschlossen sind oder bis das angegebene Timeout erreicht ist. Dadurch wird sichergestellt, dass die Datenvalidierung und die Datenbankspeicherung erst erfolgen, wenn alle Threads ihre Arbeit abgeschlossen haben.

Das obige ist der detaillierte Inhalt vonWie kann sichergestellt werden, dass alle Java-Threads abgeschlossen sind, bevor fortgefahren wird?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!