Freigeben über


Java.Util.Concurrent Namespace

Ausführungen.

Klassen ThreadPoolExecutor und ScheduledThreadPoolExecutor bieten tunbare, flexible Threadpools.

Klassen

AbstractExecutorService

Stellt Standardimplementierungen von ExecutorService Ausführungsmethoden bereit.

ArrayBlockingQueue

Eine gebundene Blockierungswarteschlange, die von einem Array unterstützt wird.

BrokenBarrierException

Ausnahme ausgelöst, wenn ein Thread versucht, auf eine Barriere zu warten, die sich in einem fehlerhaften Zustand befindet oder der während des Wartens des Threads in den fehlerhaften Zustand wechselt.

CancellationException

Ausnahme, die angibt, dass das Ergebnis eines wertproduzierenden Vorgangs, z. B. eines FutureTask, nicht abgerufen werden kann, weil der Vorgang abgebrochen wurde.

CompletableFuture

Eine Future , die explizit abgeschlossen werden kann (Festlegen des Werts und Status) und kann als CompletionStageeine, unterstützende abhängige Funktionen und Aktionen verwendet werden, die nach Abschluss des Vorgangs ausgelöst werden.

CompletionException

Ausnahme ausgelöst, wenn beim Abschließen eines Ergebnisses oder einer Aufgabe ein Fehler oder eine andere Ausnahme aufgetreten ist.

ConcurrentHashMap

Eine Hashtabelle, die die vollständige Parallelität von Abrufen und eine hohe erwartete Parallelität für Updates unterstützt.

ConcurrentLinkedDeque

Eine ungebundene gleichzeitige Deque deque basierend auf verknüpften Knoten.

ConcurrentLinkedQueue

Eine ungebundene threadsichere Warteschlangenwarteschlange basierend auf verknüpften Knoten.

ConcurrentSkipListMap

Eine skalierbare gleichzeitige ConcurrentNavigableMap Implementierung.

CopyOnWriteArrayList

Eine threadsichere Variante, in der java.util.ArrayList alle mutativen Vorgänge (add, usw.) implementiert werden, setindem eine neue Kopie des zugrunde liegenden Arrays vorgenommen wird.

CopyOnWriteArraySet

A Set that uses an internal CopyOnWriteArrayList for all of its operations.

CountDownLatch

Eine Synchronisierungshilfe, mit der mindestens ein Threads warten kann, bis eine Reihe von Vorgängen in anderen Threads abgeschlossen wird.

CountedCompleter

A ForkJoinTask with a completion action perform when triggered and there are no remaining pending actions.

CyclicBarrier

Eine Synchronisierungshilfe, mit der eine Reihe von Threads alle aufeinander warten können, um einen gemeinsamen Sperrpunkt zu erreichen.

DelayQueue

Eine ungebundene Blockierungswarteschlange mit Delayed Elementen, in der ein Element nur ausgeführt werden kann, wenn seine Verzögerung abgelaufen ist.

Exchanger

Ein Synchronisierungspunkt, an dem Threads Elemente innerhalb von Paaren koppeln und austauschen können.

ExecutionException

Ausnahme ausgelöst, wenn versucht wird, das Ergebnis einer Aufgabe abzurufen, die abgebrochen wurde, indem eine Ausnahme ausgelöst wird.

ExecutorCompletionService

A CompletionService that uses a supplied Executor to execute tasks.

Executors

Factory- und Hilfsmethoden für Executorin diesem Paket definierte Klassen , ExecutorService, , ScheduledExecutorServiceThreadFactoryund Callable Klassen.

Flow

In Beziehung stehende Schnittstellen und statische Methoden zum Einrichten von flussgesteuerten Komponenten, in denen elemente erzeugt werden, die Publisher Publishers von einem oder Subscriber Subscribersmehreren von einem Subscription Subscriptionverwalteten Element verbraucht werden.

ForkJoinPool

Eine ExecutorService für die Ausführung ForkJoinTaskvon s.

ForkJoinTask

Abstrakte Basisklasse für Aufgaben, die in einem ForkJoinPool.

ForkJoinWorkerThread

Ein von einem ForkJoinPoolThread verwalteter Thread, der s ausführt ForkJoinTask.

FutureTask

Eine abbruchfähige asynchrone Berechnung.

IBlockingDequeExtensions

Ausführungen.

Klassen ThreadPoolExecutor und ScheduledThreadPoolExecutor bieten tunbare, flexible Threadpools.

IBlockingQueueExtensions

Ausführungen.

Klassen ThreadPoolExecutor und ScheduledThreadPoolExecutor bieten tunbare, flexible Threadpools.

IExecutorServiceExtensions

Ausführungen.

Klassen ThreadPoolExecutor und ScheduledThreadPoolExecutor bieten tunbare, flexible Threadpools.

IFutureExtensions

Ausführungen.

Klassen ThreadPoolExecutor und ScheduledThreadPoolExecutor bieten tunbare, flexible Threadpools.

LinkedBlockingDeque

Eine optional gebundene BlockingDeque-Blockierung basierend auf verknüpften Knoten.

LinkedBlockingQueue

Eine optional gebundene Blockierungswarteschlange basierend auf verknüpften Knoten.

LinkedTransferQueue

Eine ungebunden basierend TransferQueue auf verknüpften Knoten.

Phaser

Eine wiederverwendbare Synchronisierungsbarriere, ähnlich der Funktionalität CyclicBarrier und CountDownLatch unterstützung einer flexibleren Nutzung.

PriorityBlockingQueue

Eine ungebundene BlockingQueue-Blockwarteschlange, die dieselben Sortierregeln wie Klassen PriorityQueue verwendet und blockierte Abrufvorgänge bereitstellt.

RecursiveAction

Ein rekursives Ergebnislos ForkJoinTask.

RecursiveTask

Rekursives Ergebnislager ForkJoinTask.

RejectedExecutionException

Ausnahme ausgelöst, wenn Executor eine Aufgabe für die Ausführung nicht akzeptiert werden kann.

ScheduledThreadPoolExecutor

Ein ThreadPoolExecutor Befehl, der zusätzlich die Ausführung nach einer bestimmten Verzögerung oder die ausführung in regelmäßigen Abständen planen kann.

Semaphore

Ein Zähl-Semaphor.

SubmissionPublisher

Eine Flow.Publisher , die übermittelte (nicht NULL)-Elemente asynchron an aktuelle Abonnenten ausgibt, bis sie geschlossen ist.

SynchronousQueue

Eine Blockierungswarteschlange, in der jeder Einfügevorgang auf einen entsprechenden Entfernungsvorgang durch einen anderen Thread warten muss und umgekehrt.

ThreadLocalRandom

Ein Zufallszahlengenerator (mit Punkt 2<sup>64</sup>) isoliert zum aktuellen Thread.

ThreadPoolExecutor

Ein ExecutorService Vorgang, der jede übermittelte Aufgabe mit einem von möglicherweise mehreren gepoolten Threads ausführt, normalerweise mit Executors Factorymethoden konfiguriert.

ThreadPoolExecutor.AbortPolicy

Ein Handler für abgelehnte Aufgaben, die einen RejectedExecutionException.

ThreadPoolExecutor.CallerRunsPolicy

Ein Handler für abgelehnte Aufgaben, die die abgelehnte Aufgabe direkt im aufrufenden Thread der execute Methode ausführen, es sei denn, der Executor wurde heruntergefahren, in diesem Fall wird die Aufgabe verworfen.

ThreadPoolExecutor.DiscardOldestPolicy

Ein Handler für abgelehnte Aufgaben, die die älteste nicht behandelte Anforderung verwirft und dann erneut ausgeführt executewird, es sei denn, der Ausführungsvorgang wird heruntergefahren, in diesem Fall wird die Aufgabe verworfen.

ThreadPoolExecutor.DiscardPolicy

Ein Handler für abgelehnte Vorgänge, die den abgelehnten Vorgang im Hintergrund verwirft.

TimeoutException

Ausnahme ausgelöst, wenn ein Blockierungsvorgang zu einem Zeitüberschreitungsvorgang ausgelöst wird.

TimeUnit

A TimeUnit stellt Zeitdauern in einer bestimmten Granularitätseinheit dar und stellt Hilfsmethoden bereit, um einheitenübergreifend zu konvertieren und Zeit- und Verzögerungsvorgänge in diesen Einheiten auszuführen.

Schnittstellen

CompletableFuture.IAsynchronousCompletionTask

Eine Markerschnittstelle, die asynchrone Aufgaben identifiziert, die von async Methoden erstellt werden.

Flow.IProcessor

Eine Komponente, die sowohl als Abonnent als auch als Publisher fungiert.

Flow.IPublisher

Ein Produzent von Elementen (und zugehörigen Steuerelementnachrichten), die von Abonnenten empfangen werden.

Flow.ISubscriber

Ein Empfänger von Nachrichten.

Flow.ISubscription

Nachrichtensteuerelement verknüpft ein Publisher und Subscriber.

ForkJoinPool.IForkJoinWorkerThreadFactory

Factory zum Erstellen neuer ForkJoinWorkerThreads.

ForkJoinPool.IManagedBlocker

Schnittstelle zum Erweitern der verwalteten Parallelität für Aufgaben, die in ForkJoinPools ausgeführt werden.

IBlockingDeque

A Deque that additionally supports blocking operations that wait for the deque to be non-empty when retrieving an element, and wait for space to be available in the deque when speicher an element.

IBlockingQueue

Eine Queue , die zusätzlich Vorgänge unterstützt, die warten, bis die Warteschlange beim Abrufen eines Elements nicht leer wird, und warten, bis Speicherplatz in der Warteschlange beim Speichern eines Elements verfügbar ist.

ICallable

Eine Aufgabe, die ein Ergebnis zurückgibt und eine Ausnahme auslösen kann.

ICompletionService

Ein Dienst, der die Produktion neuer asynchroner Vorgänge vom Verbrauch der Ergebnisse abgeschlossener Aufgaben entkoppelt.

ICompletionStage

Eine Phase einer möglicherweise asynchronen Berechnung, die eine Aktion ausführt oder einen Wert berechnet, wenn eine andere CompletionStage abgeschlossen ist.

IConcurrentMap

Eine Map Bereitstellung von Threadsicherheits- und Atomitätsgarantien.

IDelayed

Eine Mix-In-Formatschnittstelle zum Markieren von Objekten, auf die nach einer bestimmten Verzögerung reagiert werden soll.

IExecutor

Ein Objekt, das gesendete Runnable Aufgaben ausführt.

IExecutorService

Eine Executor Methode, die Methoden zum Verwalten von Beendigung und Methoden bereitstellt, die einen Fortschritt für die Future Nachverfolgung eines oder mehrerer asynchroner Aufgaben erzeugen können.

IFuture

A Future stellt das Ergebnis einer asynchronen Berechnung dar.

IRejectedExecutionHandler

Ein Handler für Aufgaben, die von einem ThreadPoolExecutor.

IRunnableFuture

Ein Future, der Runnable ist.

IRunnableScheduledFuture

Ein ScheduledFuture, der Runnable ist.

IScheduledExecutorService

Ein ExecutorService Befehl, der nach einer bestimmten Verzögerung ausgeführt werden kann oder in regelmäßigen Abständen ausgeführt werden kann.

IScheduledFuture

Eine verzögerte Ergebnislageraktion, die abgebrochen werden kann.

IThreadFactory

Ein Objekt, das neue Threads bei Bedarf erstellt.

ITransferQueue

Eine BlockingQueue , in der die Hersteller warten können, bis die Verbraucher Elemente erhalten.