Condividi tramite


Java.Util.Concurrent Spazio dei nomi

Implementazioni.

ThreadPoolExecutor Classi e ScheduledThreadPoolExecutor forniscono pool di thread flessibili e ottimizzabili.

Classi

AbstractExecutorService

Fornisce implementazioni predefinite dei metodi di ExecutorService esecuzione.

ArrayBlockingQueue

Coda di blocco associata supportata da una matrice.

BrokenBarrierException

Eccezione generata quando un thread tenta di attendere una barriera in uno stato interrotto o che entra nello stato interrotto mentre il thread è in attesa.

CancellationException

Eccezione che indica che il risultato di un'attività di produzione di valori, ad esempio , FutureTasknon può essere recuperata perché l'attività è stata annullata.

CompletableFuture

Oggetto Future che può essere completato in modo esplicito (impostandone il valore e lo stato) e può essere usato come CompletionStage, supportando funzioni dipendenti e azioni che si attivano al completamento.

CompletionException

Eccezione generata quando si verifica un errore o un'altra eccezione durante il completamento di un risultato o di un'attività.

ConcurrentHashMap

Tabella hash che supporta la concorrenza completa dei recupero e della concorrenza elevata prevista per gli aggiornamenti.

ConcurrentLinkedDeque

Deque deque simultanea non associato in base ai nodi collegati.

ConcurrentLinkedQueue

Coda di accodamento thread-safe non associato basata su nodi collegati.

ConcurrentSkipListMap

Implementazione simultanea ConcurrentNavigableMap scalabile.

CopyOnWriteArrayList

Variante thread-safe di java.util.ArrayList in cui tutte le operazioni mutative (add, sete così via) vengono implementate creando una nuova copia della matrice sottostante.

CopyOnWriteArraySet

Oggetto Set che utilizza un oggetto interno CopyOnWriteArrayList per tutte le operazioni.

CountDownLatch

Supporto per la sincronizzazione che consente a uno o più thread di attendere il completamento di un set di operazioni in altri thread.

CountedCompleter

Oggetto ForkJoinTask con un'azione di completamento eseguita quando viene attivato e non sono presenti azioni in sospeso rimanenti.

CyclicBarrier

Un aiuto di sincronizzazione che consente a un set di thread di attendere l'uno dall'altro di raggiungere un punto di barriera comune.

DelayQueue

Coda di Delayed blocco di elementi non associata, in cui un elemento può essere preso solo quando il ritardo è scaduto.

Exchanger

Punto di sincronizzazione in cui i thread possono associare e scambiare elementi all'interno di coppie.

ExecutionException

Eccezione generata quando si tenta di recuperare il risultato di un'attività interrotta generando un'eccezione.

ExecutorCompletionService

Oggetto CompletionService che utilizza un oggetto fornito Executor per eseguire le attività.

Executors

Metodi di factory e utilità per Executorle classi , ExecutorServiceScheduledExecutorService, ThreadFactory, e Callable definite in questo pacchetto.

Flow

Interfacce correlate e metodi statici per stabilire componenti controllati dal flusso in cui Publisher Publishers produrre elementi utilizzati da uno o più Subscriber Subscribers, ognuno gestito da un oggetto Subscription Subscription.

ForkJoinPool

Oggetto ExecutorService per l'esecuzione ForkJoinTaskdi s.

ForkJoinTask

Classe di base astratta per le attività eseguite all'interno di un oggetto ForkJoinPool.

ForkJoinWorkerThread

Thread gestito da un ForkJoinPoologgetto , che esegue ForkJoinTasks.

FutureTask

Calcolo asincrono annullabile.

IBlockingDequeExtensions

Implementazioni.

ThreadPoolExecutor Classi e ScheduledThreadPoolExecutor forniscono pool di thread flessibili e ottimizzabili.

IBlockingQueueExtensions

Implementazioni.

ThreadPoolExecutor Classi e ScheduledThreadPoolExecutor forniscono pool di thread flessibili e ottimizzabili.

IExecutorServiceExtensions

Implementazioni.

ThreadPoolExecutor Classi e ScheduledThreadPoolExecutor forniscono pool di thread flessibili e ottimizzabili.

IFutureExtensions

Implementazioni.

ThreadPoolExecutor Classi e ScheduledThreadPoolExecutor forniscono pool di thread flessibili e ottimizzabili.

LinkedBlockingDeque

Deque bloccante facoltativamente delimitato da BlockingDeque in base ai nodi collegati.

LinkedBlockingQueue

Coda di blocco bloccata facoltativamente associata in base ai nodi collegati.

LinkedTransferQueue

Un oggetto non associato TransferQueue in base ai nodi collegati.

Phaser

Una barriera di sincronizzazione riutilizzabile, simile alla funzionalità e CyclicBarrierCountDownLatch al supporto di un utilizzo più flessibile.

PriorityBlockingQueue

Coda di blocco BlockingQueue non associato che usa le stesse regole di ordinamento della classe PriorityQueue e fornisce operazioni di recupero bloccanti.

RecursiveAction

Oggetto senza ForkJoinTaskrisultato ricorsivo.

RecursiveTask

Risultato ricorsivo ForkJoinTask.

RejectedExecutionException

Eccezione generata da un oggetto quando un'attività Executor non può essere accettata per l'esecuzione.

ScheduledThreadPoolExecutor

Oggetto ThreadPoolExecutor che può inoltre pianificare l'esecuzione dei comandi dopo un determinato ritardo o per l'esecuzione periodica.

Semaphore

Semaforo di conteggio.

SubmissionPublisher

Oggetto Flow.Publisher che rilascia in modo asincrono gli elementi inviati (non Null) ai sottoscrittori correnti fino a quando non viene chiuso.

SynchronousQueue

Coda di blocco BlockingQueue in cui ogni operazione di inserimento deve attendere un'operazione di rimozione corrispondente da un altro thread e viceversa.

ThreadLocalRandom

Generatore di numeri casuali (con punto 2<sup 64</sup>) isolato>al thread corrente.

ThreadPoolExecutor

Oggetto ExecutorService che esegue ogni attività inviata usando uno dei thread eventualmente in pool, normalmente configurati usando Executors i metodi factory.

ThreadPoolExecutor.AbortPolicy

Gestore per le attività rifiutate che genera un'eccezione RejectedExecutionException.

ThreadPoolExecutor.CallerRunsPolicy

Gestore per le attività rifiutate che esegue l'attività rifiutata direttamente nel thread chiamante del execute metodo, a meno che l'executor non sia stato arrestato, nel qual caso l'attività viene eliminata.

ThreadPoolExecutor.DiscardOldestPolicy

Gestore per le attività rifiutate che elimina la richiesta non gestita meno recente e quindi ritenta execute, a meno che l'executor non venga arrestato, nel qual caso l'attività viene rimossa.

ThreadPoolExecutor.DiscardPolicy

Gestore per le attività rifiutate che elimina automaticamente l'attività rifiutata.

TimeoutException

Eccezione generata quando si verifica il timeout di un'operazione di blocco.

TimeUnit

Un TimeUnit oggetto rappresenta le durate temporali in una determinata unità di granularità e fornisce metodi di utilità per la conversione tra unità e per eseguire operazioni di intervallo e ritardo in queste unità.

Interfacce

CompletableFuture.IAsynchronousCompletionTask

Interfaccia dell'indicatore che identifica le attività asincrone prodotte dai async metodi.

Flow.IProcessor

Componente che funge sia da Sottoscrittore che da server di pubblicazione.

Flow.IPublisher

Produttore di elementi (e messaggi di controllo correlati) ricevuti dai Sottoscrittori.

Flow.ISubscriber

Ricevitore di messaggi.

Flow.ISubscription

Controllo messaggio che collega un oggetto Publisher e Subscriber.

ForkJoinPool.IForkJoinWorkerThreadFactory

Factory per la creazione di nuovi ForkJoinWorkerThreadelementi.

ForkJoinPool.IManagedBlocker

Interfaccia per estendere il parallelismo gestito per le attività in esecuzione in ForkJoinPools.

IBlockingDeque

Oggetto Deque che supporta inoltre operazioni di blocco che attendono che la deque diventi non vuota durante il recupero di un elemento e attendi che lo spazio diventi disponibile nella deque durante l'archiviazione di un elemento.

IBlockingQueue

Oggetto Queue che supporta anche operazioni che attendono che la coda diventi non vuota durante il recupero di un elemento e attenda che lo spazio diventi disponibile nella coda durante l'archiviazione di un elemento.

ICallable

Un'attività che restituisce un risultato e può generare un'eccezione.

ICompletionService

Servizio che separa la produzione di nuove attività asincrone dal consumo dei risultati delle attività completate.

ICompletionStage

Fase di un calcolo possibilmente asincrono, che esegue un'azione o calcola un valore al termine di un'altra operazione CompletionStage.

IConcurrentMap

Garanzia Map di thread safety e atomicità.

IDelayed

Interfaccia di stile mix-in per contrassegnare gli oggetti che devono essere eseguiti dopo un determinato ritardo.

IExecutor

Oggetto che esegue le attività inviate Runnable .

IExecutorService

Oggetto Executor che fornisce metodi per gestire la terminazione e i metodi che possono produrre un Future oggetto per tenere traccia dello stato di avanzamento di una o più attività asincrone.

IFuture

Un Future oggetto rappresenta il risultato di un calcolo asincrono.

IRejectedExecutionHandler

Gestore per le attività che non possono essere eseguite da un oggetto ThreadPoolExecutor.

IRunnableFuture

Oggetto Future che è Runnable.

IRunnableScheduledFuture

Oggetto ScheduledFuture che è Runnable.

IScheduledExecutorService

Oggetto ExecutorService che può pianificare l'esecuzione dei comandi dopo un determinato ritardo o per l'esecuzione periodica.

IScheduledFuture

Azione ritardata che può essere annullata.

IThreadFactory

Oggetto che crea nuovi thread su richiesta.

ITransferQueue

Oggetto BlockingQueue in cui i produttori possono attendere che i consumer ricevano elementi.