Поделиться через


Java.Util.Concurrent Пространство имен

Реализации.

Классы ThreadPoolExecutor и ScheduledThreadPoolExecutor предоставляют настраиваемые пулы гибких потоков.

Классы

AbstractExecutorService

Предоставляет реализации ExecutorService методов выполнения по умолчанию.

ArrayBlockingQueue

Ограниченная очередь блокировки БлокироватьQueue, поддерживаемая массивом.

BrokenBarrierException

Исключение возникает, когда поток пытается дождаться барьера, который находится в сломанном состоянии, или который входит в сломанное состояние во время ожидания потока.

CancellationException

Исключение, указывающее, что результат задачи создания значений, например, FutureTaskневозможно получить, так как задача была отменена.

CompletableFuture

Объект Future , который может быть явно завершен (задать его значение и состояние), и может использоваться в качестве CompletionStageподдержки зависимых функций и действий, которые активируются после его завершения.

CompletionException

Исключение возникает при возникновении ошибки или другого исключения в ходе выполнения результата или задачи.

ConcurrentHashMap

Хэш-таблица, поддерживающая полный параллелизм повторных вычислений и высокий ожидаемый параллелизм для обновлений.

ConcurrentLinkedDeque

Необязаемый одновременный deque deque на основе связанных узлов.

ConcurrentLinkedQueue

Несоединяемая очередь в потокобезопасной очереди на основе связанных узлов.

ConcurrentSkipListMap

Масштабируемая параллельная ConcurrentNavigableMap реализация.

CopyOnWriteArrayList

Потокобезопасный вариант java.util.ArrayList , в котором реализуются все мутативные операции (addи setт. д.) путем создания новой копии базового массива.

CopyOnWriteArraySet

Объект, Set который использует внутреннюю CopyOnWriteArrayList для всех своих операций.

CountDownLatch

Помощь синхронизации, которая позволяет одному или нескольким потокам ожидать завершения набора операций в других потоках.

CountedCompleter

Действие ForkJoinTask завершения, выполняемое при активации и отсутствие оставшихся ожидающих действий.

CyclicBarrier

Помощь синхронизации, которая позволяет набору потоков ждать друг друга, чтобы достичь общей точки барьера.

DelayQueue

Несвязанная очередь Delayed блокирующих элементов, в которой элемент может приниматься только при истечении срока его задержки.

Exchanger

Точка синхронизации, в которой потоки могут связывать и переключать элементы в парах.

ExecutionException

Исключение, возникающее при попытке получить результат задачи, прерванной путем создания исключения.

ExecutorCompletionService

Объект, CompletionService который использует предоставленный Executor для выполнения задач.

Executors

Методы фабрики и Callable служебной программы для Executor, ExecutorServiceи ScheduledExecutorServiceThreadFactoryклассов, определенных в этом пакете.

Flow

Взаимосвязанные интерфейсы и статические методы для создания управляемых потоком компонентов, в которых Publisher Publishers создаются элементы, потребляемые одним или несколькими Subscriber Subscribers, каждый из которых управляется Subscription Subscription.

ForkJoinPool

An ExecutorService for running ForkJoinTasks.

ForkJoinTask

Абстрактный базовый класс для задач, выполняемых в пределах ForkJoinPool.

ForkJoinWorkerThread

Поток, управляемый объектом ForkJoinPool, который выполняется ForkJoinTask.

FutureTask

Отменяемое асинхронное вычисление.

IBlockingDequeExtensions

Реализации.

Классы ThreadPoolExecutor и ScheduledThreadPoolExecutor предоставляют настраиваемые пулы гибких потоков.

IBlockingQueueExtensions

Реализации.

Классы ThreadPoolExecutor и ScheduledThreadPoolExecutor предоставляют настраиваемые пулы гибких потоков.

IExecutorServiceExtensions

Реализации.

Классы ThreadPoolExecutor и ScheduledThreadPoolExecutor предоставляют настраиваемые пулы гибких потоков.

IFutureExtensions

Реализации.

Классы ThreadPoolExecutor и ScheduledThreadPoolExecutor предоставляют настраиваемые пулы гибких потоков.

LinkedBlockingDeque

Необязательный блокировка BlockingDeque, основанная на связанных узлах.

LinkedBlockingQueue

При необходимости привязанная очередь блокировки БлокировкиQueue на основе связанных узлов.

LinkedTransferQueue

Несвязанный TransferQueue на основе связанных узлов.

Phaser

Повторно используемый барьер синхронизации, аналогичный функциональным CyclicBarrier возможностям и CountDownLatch поддержке более гибкого использования.

PriorityBlockingQueue

Несвязанная очередь блокировки BlockingQueue, использующая те же правила упорядочения, что и класс PriorityQueue и предоставляет блокирующие операции извлечения.

RecursiveAction

Рекурсивный результат без ForkJoinTaskрезультата.

RecursiveTask

Рекурсивный результат.ForkJoinTask

RejectedExecutionException

Исключение, возникающее при Executor невозможности принятия задачи для выполнения.

ScheduledThreadPoolExecutor

Объект, ThreadPoolExecutor который также может запланировать выполнение команд после заданной задержки или периодически выполняться.

Semaphore

Подсчет семафора.

SubmissionPublisher

Асинхронно Flow.Publisher выдает отправленные (непустые) элементы текущим подписчикам до его закрытия.

SynchronousQueue

Очередь блокировки БлокироватьQueue, в которой каждая операция вставки должна ожидать соответствующей операции удаления другим потоком и наоборот.

ThreadLocalRandom

Генератор случайных чисел (с периодом 2<sup 64</sup>), изолированный для>текущего потока.

ThreadPoolExecutor

При ExecutorService выполнении каждой отправленной задачи используется один из нескольких пуловых потоков, обычно настроенный с помощью Executors методов фабрики.

ThreadPoolExecutor.AbortPolicy

Обработчик отклоненных задач, который создает RejectedExecutionExceptionисключение.

ThreadPoolExecutor.CallerRunsPolicy

Обработчик отклоненных задач, выполняющих отклоненную задачу непосредственно в вызывающем потоке execute метода, если не был завершен выполнение задачи, в этом случае задача будет отменена.

ThreadPoolExecutor.DiscardOldestPolicy

Обработчик отклоненных задач, отменяющий старый необработанные запросы, а затем повторные executeпопытки, если исполнитель не завершит работу, в этом случае задача будет отменена.

ThreadPoolExecutor.DiscardPolicy

Обработчик отклоненных задач, которые автоматически отменяют отклоненную задачу.

TimeoutException

Исключение, возникающее при истечении времени ожидания блокирующей операции.

TimeUnit

Представляет TimeUnit длительность времени в заданной единице детализации и предоставляет служебные методы для преобразования между единицами, а также для выполнения операций времени и задержки в этих единицах.

Интерфейсы

CompletableFuture.IAsynchronousCompletionTask

Интерфейс маркера, определяющий асинхронные задачи, созданные async методами.

Flow.IProcessor

Компонент, который выступает как подписчиком, так и издателем.

Flow.IPublisher

Производитель элементов (и связанных контрольных сообщений), полученных подписчиками.

Flow.ISubscriber

Получатель сообщений.

Flow.ISubscription

Элемент управления сообщением, связывающий объект Publisher и Subscriber.

ForkJoinPool.IForkJoinWorkerThreadFactory

Фабрика для создания новых ForkJoinWorkerThreadверсий.

ForkJoinPool.IManagedBlocker

Интерфейс расширения управляемого параллелизма для задач, выполняемых в ForkJoinPools.

IBlockingDeque

Кроме Deque того, поддерживается блокировка операций, ожидающих того, что deque станет непустой при получении элемента, и дождитесь того, чтобы пространство стало доступным в deque при хранении элемента.

IBlockingQueue

Это Queue также поддерживает операции, ожидающие того, что очередь станет непустой при получении элемента, и дождитесь того, чтобы пространство стало доступным в очереди при хранении элемента.

ICallable

Задача, которая возвращает результат и может вызвать исключение.

ICompletionService

Служба, которая отделяет производство новых асинхронных задач от потребления результатов завершенных задач.

ICompletionStage

Этап возможно асинхронного вычисления, который выполняет действие или вычисляет значение при завершении другого завершения.

IConcurrentMap

Обеспечение Map гарантий безопасности потоков и атомарности.

IDelayed

Интерфейс стиля смешанного стиля для маркировки объектов, которые должны выполняться после заданной задержки.

IExecutor

Объект, выполняющий отправленные Runnable задачи.

IExecutorService

Методы Executor управления завершением и методами, которые могут создавать Future для отслеживания хода выполнения одной или нескольких асинхронных задач.

IFuture

Представляет Future результат асинхронного вычисления.

IRejectedExecutionHandler

Обработчик для задач, которые не могут выполняться с помощью .ThreadPoolExecutor

IRunnableFuture

То Future есть Runnable.

IRunnableScheduledFuture

То ScheduledFuture есть Runnable.

IScheduledExecutorService

Может ExecutorService запланировать выполнение команд после заданной задержки или периодически выполняться.

IScheduledFuture

Отложенное действие, которое может быть отменено.

IThreadFactory

Объект, создающий новые потоки по запросу.

ITransferQueue

Объект, BlockingQueue в котором производители могут ждать получения элементов потребителями.