So verwenden Sie den Thread-Pool in Java 7, um die regelmäßige Ausführung von Aufgaben und die Ergebnisverarbeitung zu implementieren

So verwenden Sie Thread-Pools in Java 7, um die regelmäßige Ausführung von Aufgaben und die Ergebnisverarbeitung zu implementieren.

Bei der Multithread-Programmierung sind Thread-Pools eine häufig verwendete Technologie, mit der die Erstellung und Zerstörung von Threads effektiv verwaltet und die Leistung des Programms verbessert werden kann . Leistung und Effizienz. In Java 7 kann das Executor-Framework problemlos einen Thread-Pool implementieren und die regelmäßige Ausführung von Aufgaben und Ergebnisverarbeitung durchführen. In diesem Artikel wird beschrieben, wie Thread-Pools zum Implementieren dieser Funktionen verwendet werden, zusammen mit entsprechenden Codebeispielen.

1. Erstellen Sie einen Thread-Pool

In Java können Sie die ExecutorService-Schnittstelle verwenden, um einen Thread-Pool zu erstellen und zu verwalten. Der einfachste Weg besteht darin, eine der statischen Methoden der Executors-Klasse zu verwenden. Sie können beispielsweise die Methode Executors.newFixedThreadPool(int n) verwenden, um einen Thread-Pool mit fester Größe zu erstellen, wobei n die Anzahl der Threads darstellt.

ExecutorService executor = Executors.newFixedThreadPool(5);

2. Führen Sie die Aufgabe aus

Als nächstes kann die Aufgabe zur Ausführung an den Thread-Pool übermittelt werden. Aufgaben können mit der Methodeexecute() an den Thread-Pool übermittelt werden. Angenommen, es gibt eine MyTask-Klasse, die die Runnable-Schnittstelle implementiert. Aufgaben können auf folgende Weise übermittelt werden:

executor.execute(new MyTask());

3. Periodische Ausführung von Aufgaben

Wenn Sie möchten, dass die Aufgabe regelmäßig ausgeführt wird, können Sie die Executors verwenden .newScheduledThreadPool(int n)-Methode Erstellen Sie einen Planungs-Thread-Pool. Wobei n die Anzahl der Threads darstellt. Anschließend können Sie die Methode „scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)“ verwenden, um die Aufgabe zur regelmäßigen Ausführung an den Thread-Pool zu senden.

ScheduledExecutorService scheduledExecutor = Executors.newScheduledThreadPool(2);
scheduledExecutor.scheduleAtFixedRate(new MyTask(), initialDelay, period, TimeUnit.SECONDS);

Im obigen Code stellt initialDelay die Verzögerungszeit (in Sekunden) für die erste Ausführung der Aufgabe dar und period stellt den Zeitraum der Aufgabe (in Sekunden) dar.

4. Aufgabenergebnisse verarbeiten

Während der Ausführung der Aufgabe kann das Ausführungsergebnis der Aufgabe über das Future-Objekt abgerufen werden. Das Future-Objekt stellt das Ergebnis einer asynchronen Operation dar und der Rückgabewert kann über die Methode get() abgerufen werden. Nachdem Sie die Aufgabe ausgeführt haben, können Sie das Future-Objekt über die Methode „submit()“ abrufen.

Future<Integer> future = executor.submit(new MyTask(), 100);
int result = future.get();

Im obigen Code kann die Methode „submit()“ ein Callable-Objekt als Parameter akzeptieren und ein Future-Objekt zurückgeben. Durch Aufrufen der Methode get() können Sie das Ausführungsergebnis der Callable-Aufgabe erhalten.

5. Schließen Sie den Thread-Pool

Wenn der Thread-Pool nicht mehr benötigt wird, sollte er geschlossen werden, um Ressourcen freizugeben. Sie können die Methode „shutdown()“ verwenden, um den Thread-Pool herunterzufahren. Der Thread-Pool führt die Aufgabe weiter aus, bis die Aufgabe abgeschlossen ist.

executor.shutdown();

Darüber hinaus können Sie auch die Methode „shutdownNow()“ verwenden, um den Thread-Pool herunterzufahren. Diese Methode versucht jedoch, alle ausgeführten Aufgaben zu unterbrechen und gibt eine Liste nicht ausgeführter Aufgaben zurück.

executor.shutdownNow();

Zusammenfassend lässt sich sagen, dass das Executor-Framework problemlos einen Thread-Pool implementieren und die regelmäßige Ausführung von Aufgaben und Ergebnisverarbeitung implementieren kann. In Java 7 kann die Verwendung von Thread-Pools die Leistung und Effizienz von Multithread-Programmen verbessern. Ich hoffe, dieser Artikel hilft Ihnen dabei, Thread-Pools zu verwenden, um die regelmäßige Ausführung von Aufgaben und die Ergebnisverarbeitung in Java zu implementieren.

Referenzquelle:

• Offizielle Oracle-Dokumentation: https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html

Das obige ist der detaillierte Inhalt vonSo verwenden Sie den Thread-Pool in Java 7, um die regelmäßige Ausführung von Aufgaben und die Ergebnisverarbeitung zu implementieren. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!