Umgang mit Multithreading in „Executor Service' Java

Der PHP-Editor Youzi gibt Ihnen die Antwort: Die Verwendung des Executor Service zur Handhabung von Multithreading in Java ist eine effiziente Möglichkeit, den Thread-Pool und den Thread-Lebenszyklus effektiv zu verwalten. Mit dem Executor Service können Sie problemlos mehrere Threads erstellen, starten und steuern, um eine gleichzeitige Ausführung von Aufgaben zu erreichen und die Programmeffizienz zu verbessern. In diesem Artikel wird erläutert, wie Sie den Executor Service zur Behandlung von Multithreading-Problemen in Java verwenden, um Ihnen dabei zu helfen, dieses wichtige Multithreading-Verarbeitungstool besser zu verstehen und anzuwenden.

Inhalt der Frage

Ich entwickle eine Lösung. Für einen einzelnen Kunden muss ich eine API aufrufen, um die Mitarbeiterliste dieses Kunden zu erhalten. Diese API (Drittanbieter) kann jedoch jeweils nur 100 Mitarbeiter zurückgeben. Daher muss ich jedes Mal dieselbe API aufrufen, indem ich den Offset ändere, um den nächsten Satz von 100 Mitarbeitern zu erhalten. Derzeit wird dies über einen einzigen Thread abgewickelt, sodass die Zeit zum Abrufen aller Mitarbeiter (sagen wir 30.000) mit zunehmender Anzahl der Mitarbeiter zunimmt. Und die App hat viele solcher Kunden.

Als Lösung für dieses Problem habe ich versucht, Multithreading mit #executorservice zu implementieren. Mit dieser Lösung wird der Zeitaufwand für das Abrufen aller Mitarbeiter für einen Kunden reduziert.

Frage:

1. Wie funktionieren mehrere Threads (von mehreren Clients) mit einem Executor-Dienst, der über mehrere Threads zum Aufrufen der API verfügt?
2. Wird die folgende Logik in einer Multithread-Umgebung dazu führen, dass der Endbenutzer falsche Daten erhält? Beispielcode:

ExecutorService executor = Executors.newFixedThreadPool(2);

  ServiceExecutor executor0 = new ServiceExecutor("0");
  ServiceExecutor executor1 = new ServiceExecutor("100");

  Future result0 = executor.submit(executor0);
  Future result1 = executor.submit(executor1);
   
  List<String> s1 = new ArrayList<>();
  s1.add(result0.get());
  s2.add(result1.get());

Workaround

Die Antwort auf diese Frage hängt größtenteils davon ab, wie Ihre Anwendung für den Empfang von Anfragen Ihrer Kunden eingerichtet ist. Wird für jede eingehende Anfrage ein neuer Executor-Service erstellt oder wird der Executor-Service von allen Anfragen gemeinsam genutzt? Das Erstellen eines neuen Executor-Dienstes für jede Anfrage wäre sehr verschwenderisch, da Sie Platz für einen neuen Thread zuweisen müssten, der nicht sehr lange verfügbar sein wird. Daher ist es effizienter, denselben ExecutorService für mehrere Anforderungen wiederzuverwenden.

In diesem Fall ist die Verwendung von Executors.newCachedThreadPool() 而不是 newFixedThreadPool() möglicherweise flexibler, da der ExecutorService dadurch die Anzahl der Threads im Pool nach Bedarf dynamisch erhöhen kann.

Das obige ist der detaillierte Inhalt vonUmgang mit Multithreading in „Executor Service' Java. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!