Partilhar via


Java.Util.Concurrent Namespace

Implementações.

Classes ThreadPoolExecutor e fornecer pools de threads ajustáveis e ScheduledThreadPoolExecutor flexíveis.

Classes

AbstractExecutorService

Fornece implementações padrão de métodos de ExecutorService execução.

ArrayBlockingQueue

Uma fila de bloqueio BlockingQueue limitada apoiada por uma matriz.

BrokenBarrierException

Exceção lançada quando um thread tenta aguardar uma barreira que está em um estado quebrado ou que entra no estado quebrado enquanto o thread está aguardando.

CancellationException

Exceção indicando que o resultado de uma tarefa de produção de valor, como um FutureTask, não pode ser recuperado porque a tarefa foi cancelada.

CompletableFuture

A Future que pode ser explicitamente concluída (definindo seu valor e status), e pode ser usada como um CompletionStage, suportando funções dependentes e ações que são acionadas após sua conclusão.

CompletionException

Exceção lançada quando um erro ou outra exceção é encontrada durante a conclusão de um resultado ou tarefa.

ConcurrentHashMap

Uma tabela de hash que oferece suporte à simultaneidade completa de recuperações e à alta simultaneidade esperada para atualizações.

ConcurrentLinkedDeque

Um Deque Deque simultâneo ilimitado baseado em nós vinculados.

ConcurrentLinkedQueue

Uma fila de fila ilimitada thread-safe com base em nós vinculados.

ConcurrentSkipListMap

Uma implementação simultânea ConcurrentNavigableMap escalável.

CopyOnWriteArrayList

Uma variante thread-safe na java.util.ArrayList qual todas as operações mutativas (add, sete assim por diante) são implementadas fazendo uma nova cópia da matriz subjacente.

CopyOnWriteArraySet

A Set que utiliza um interno CopyOnWriteArrayList para todas as suas operações.

CountDownLatch

Um auxílio de sincronização que permite que um ou mais threads aguardem até que um conjunto de operações que estão sendo executadas em outros threads seja concluído.

CountedCompleter

A ForkJoinTask com uma ação de conclusão executada quando acionada e não há ações pendentes restantes.

CyclicBarrier

Um auxílio de sincronização que permite que um conjunto de threads esperem um pelo outro para alcançar um ponto de barreira comum.

DelayQueue

Uma fila de Delayed elementos de bloqueio BlockingQueue não limitada, na qual um elemento só pode ser usado quando seu atraso expirou.

Exchanger

Um ponto de sincronização no qual os threads podem emparelhar e trocar elementos dentro de pares.

ExecutionException

Exceção lançada ao tentar recuperar o resultado de uma tarefa que foi abortada lançando uma exceção.

ExecutorCompletionService

A CompletionService que usa um fornecido Executor para executar tarefas.

Executors

Métodos de fábrica e utilitário para Executor, ExecutorService, ScheduledExecutorServiceThreadFactory, e Callable classes definidas neste pacote.

Flow

Interfaces inter-relacionadas e métodos estáticos para estabelecer componentes controlados por fluxo nos quais Publisher Publishers produzem itens consumidos por um ou mais Subscriber Subscribers, cada um gerenciado por um Subscription Subscription.

ForkJoinPool

Um ExecutorService para correr ForkJoinTasks.

ForkJoinTask

Classe base abstrata para tarefas executadas em um ForkJoinPoolarquivo .

ForkJoinWorkerThread

Um thread gerenciado por um ForkJoinPool, que executa ForkJoinTasks.

FutureTask

Uma computação assíncrona cancelável.

IBlockingDequeExtensions

Implementações.

Classes ThreadPoolExecutor e fornecer pools de threads ajustáveis e ScheduledThreadPoolExecutor flexíveis.

IBlockingQueueExtensions

Implementações.

Classes ThreadPoolExecutor e fornecer pools de threads ajustáveis e ScheduledThreadPoolExecutor flexíveis.

IExecutorServiceExtensions

Implementações.

Classes ThreadPoolExecutor e fornecer pools de threads ajustáveis e ScheduledThreadPoolExecutor flexíveis.

IFutureExtensions

Implementações.

Classes ThreadPoolExecutor e fornecer pools de threads ajustáveis e ScheduledThreadPoolExecutor flexíveis.

LinkedBlockingDeque

Um deque de bloqueio BlockingDeque opcionalmente limitado com base em nós vinculados.

LinkedBlockingQueue

Uma fila de bloqueio BlockingQueue limitada opcionalmente com base em nós vinculados.

LinkedTransferQueue

Um ilimitado baseado em nós vinculados TransferQueue .

Phaser

Uma barreira de sincronização reutilizável, semelhante em funcionalidade e CyclicBarrierCountDownLatch mas que suporta um uso mais flexível.

PriorityBlockingQueue

Uma fila de bloqueio BlockingQueue ilimitada que usa as mesmas regras de ordenação que as operações de recuperação de bloqueio de classe PriorityQueue e suprimentos.

RecursiveAction

Um resultado ForkJoinTaskrecursivo.

RecursiveTask

Um resultado ForkJoinTaskrecursivo.

RejectedExecutionException

Exceção lançada por um Executor quando uma tarefa não pode ser aceita para execução.

ScheduledThreadPoolExecutor

Um ThreadPoolExecutor que também pode agendar comandos para serem executados após um determinado atraso ou para serem executados periodicamente.

Semaphore

Um semáforo de contagem.

SubmissionPublisher

A Flow.Publisher que emite de forma assíncrona itens enviados (não nulos) para assinantes atuais até que seja fechado.

SynchronousQueue

Uma fila de bloqueio BlockingQueue na qual cada operação de inserção deve aguardar uma operação de remoção correspondente por outro thread e vice-versa.

ThreadLocalRandom

Um gerador de números aleatórios (com ponto 2<sup>64</sup>) isolado para o thread atual.

ThreadPoolExecutor

Um ExecutorService que executa cada tarefa enviada usando um dos possivelmente vários threads em pool, normalmente configurados usando Executors métodos de fábrica.

ThreadPoolExecutor.AbortPolicy

Um manipulador para tarefas rejeitadas que lança um RejectedExecutionExceptionarquivo .

ThreadPoolExecutor.CallerRunsPolicy

Um manipulador para tarefas rejeitadas que executa a tarefa rejeitada diretamente no thread de chamada do método, a execute menos que o executor tenha sido desligado, caso em que a tarefa será descartada.

ThreadPoolExecutor.DiscardOldestPolicy

Um manipulador para tarefas rejeitadas que descarta a solicitação não tratada mais antiga e, em seguida, tenta executenovamente, a menos que o executor seja desligado, caso em que a tarefa é descartada.

ThreadPoolExecutor.DiscardPolicy

Um manipulador para tarefas rejeitadas que descarta silenciosamente a tarefa rejeitada.

TimeoutException

Exceção lançada quando uma operação de bloqueio atinge o tempo limite.

TimeUnit

A TimeUnit representa durações de tempo em uma determinada unidade de granularidade e fornece métodos de utilidade para converter entre unidades e executar operações de tempo e atraso nessas unidades.

Interfaces

CompletableFuture.IAsynchronousCompletionTask

Uma interface de marcador que identifica tarefas assíncronas produzidas por async métodos.

Flow.IProcessor

Um componente que atua como Assinante e Publicador.

Flow.IPublisher

Um produtor de itens (e mensagens de controle relacionadas) recebidos por assinantes.

Flow.ISubscriber

Um receptor de mensagens.

Flow.ISubscription

Controle de mensagem vinculando a Publisher e Subscriber.

ForkJoinPool.IForkJoinWorkerThreadFactory

Fábrica para criação de novos ForkJoinWorkerThreads.

ForkJoinPool.IManagedBlocker

Interface para estender o paralelismo gerenciado para tarefas em execução em ForkJoinPools.

IBlockingDeque

Um Deque que também oferece suporte a operações de bloqueio que aguardam que o deque se torne não vazio ao recuperar um elemento e esperam que o espaço fique disponível no deque ao armazenar um elemento.

IBlockingQueue

Um Queue que também oferece suporte a operações que aguardam que a fila se torne não vazia ao recuperar um elemento e aguardam que o espaço fique disponível na fila ao armazenar um elemento.

ICallable

Uma tarefa que retorna um resultado e pode lançar uma exceção.

ICompletionService

Um serviço que dissocia a produção de novas tarefas assíncronas do consumo dos resultados de tarefas concluídas.

ICompletionStage

Um estágio de uma computação possivelmente assíncrona, que executa uma ação ou calcula um valor quando outro CompletionStage é concluído.

IConcurrentMap

Uma Map garantia de segurança e atomicidade das roscas.

IDelayed

Uma interface de estilo misto para marcar objetos que devem ser acionados após um determinado atraso.

IExecutor

Um objeto que executa tarefas enviadas Runnable .

IExecutorService

Um Executor que fornece métodos para gerenciar terminação e métodos que podem produzir um para controlar o Future progresso de uma ou mais tarefas assíncronas.

IFuture

A Future representa o resultado de uma computação assíncrona.

IRejectedExecutionHandler

Um manipulador para tarefas que não podem ser executadas por um ThreadPoolExecutorarquivo .

IRunnableFuture

Um Future que é Runnable.

IRunnableScheduledFuture

Um ScheduledFuture que é Runnable.

IScheduledExecutorService

Um ExecutorService que pode agendar comandos para executar após um determinado atraso ou para executar periodicamente.

IScheduledFuture

Uma ação atrasada que pode ser cancelada.

IThreadFactory

Um objeto que cria novos threads sob demanda.

ITransferQueue

Um BlockingQueue em que os produtores podem esperar que os consumidores recebam elementos.