java.util.concurrent
Interfaces
BlockingDeque |
A |
BlockingQueue |
A |
Callable |
A task that returns a result and may throw an exception. |
AsynchronousCompletionTask |
A marker interface identifying asynchronous tasks produced by |
CompletionService |
A service that decouples the production of new asynchronous tasks from the consumption of the results of completed tasks. |
CompletionStage |
A stage of a possibly asynchronous computation, that performs an action or computes a value when another CompletionStage completes. |
ConcurrentMap |
A |
ConcurrentNavigableMap |
A |
Delayed |
A mix-in style interface for marking objects that should be acted upon after a given delay. |
Executor |
An object that executes submitted |
ExecutorService |
An |
Processor |
A component that acts as both a Subscriber and Publisher. |
Publisher |
A producer of items (and related control messages) received by Subscribers. |
Subscriber |
A receiver of messages. |
Subscription |
Message control linking a |
ForkJoinWorkerThreadFactory |
Factory for creating new |
ManagedBlocker |
Interface for extending managed parallelism for tasks running in |
Future |
A represents the result of an asynchronous computation. |
RejectedExecutionHandler |
A handler for tasks that cannot be executed by a |
RunnableFuture | |
RunnableScheduledFuture |
A |
ScheduledExecutorService |
An |
ScheduledFuture |
A delayed result-bearing action that can be cancelled. |
ThreadFactory |
An object that creates new threads on demand. |
TransferQueue |
A |
Classes
AbstractExecutorService |
Provides default implementations of |
ArrayBlockingQueue |
A bounded blocking queue backed by an array. |
CompletableFuture |
A |
ConcurrentHashMap |
A hash table supporting full concurrency of retrievals and high expected concurrency for updates. |
ConcurrentLinkedDeque |
An unbounded concurrent deque based on linked nodes. |
ConcurrentLinkedQueue |
An unbounded thread-safe queue based on linked nodes. |
ConcurrentSkipListMap |
A scalable concurrent |
ConcurrentSkipListSet |
A scalable concurrent |
CopyOnWriteArrayList |
A thread-safe variant of |
CopyOnWriteArraySet |
A |
CountDownLatch |
A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes. |
CountedCompleter |
A |
CyclicBarrier |
A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point. |
DelayQueue |
An unbounded blocking queue of |
Exchanger |
A synchronization point at which threads can pair and swap elements within pairs. |
ExecutorCompletionService |
A |
Executors |
Factory and utility methods for |
Flow |
Interrelated interfaces and static methods for establishing flow-controlled components in which |
ForkJoinPool |
An |
ForkJoinTask |
Abstract base class for tasks that run within a |
ForkJoinWorkerThread |
A thread managed by a |
FutureTask |
A cancellable asynchronous computation. |
LinkedBlockingDeque |
An optionally-bounded blocking deque based on linked nodes. |
LinkedBlockingQueue |
An optionally-bounded blocking queue based on linked nodes. |
LinkedTransferQueue |
An unbounded |
Phaser |
A reusable synchronization barrier, similar in functionality to |
PriorityBlockingQueue |
An unbounded blocking queue that uses the same ordering rules as class |
RecursiveAction |
A recursive resultless |
RecursiveTask |
A recursive result-bearing |
ScheduledThreadPoolExecutor |
A |
Semaphore |
A counting semaphore. |
SubmissionPublisher |
A |
SynchronousQueue |
A blocking queue in which each insert operation must wait for a corresponding remove operation by another thread, and vice versa. |
ThreadLocalRandom |
A random number generator (with period 264) isolated to the current thread. |
ThreadPoolExecutor |
An |
Exceptions
BrokenBarrierException |
Exception thrown when a thread tries to wait upon a barrier that is in a broken state, or which enters the broken state while the thread is waiting. |
CancellationException |
Exception indicating that the result of a value-producing task, such as a |
CompletionException |
Exception thrown when an error or other exception is encountered in the course of completing a result or task. |
ExecutionException |
Exception thrown when attempting to retrieve the result of a task that aborted by throwing an exception. |
RejectedExecutionException |
Exception thrown by an |
TimeoutException |
Exception thrown when a blocking operation times out. |
Enums
TimeUnit |
A represents time durations at a given unit of granularity and provides utility methods to convert across units, and to perform timing and delay operations in these units. |