Package groovy.concurrent

package groovy.concurrent

Structured concurrency abstractions for asynchronous and parallel programming.

Provides high-level concurrency primitives: Actor (message-passing), AsyncScope (structured concurrency), Pool (thread management), and ParallelScope (combined async+parallel). Supports virtual threads (JDK 21+) and fail-fast exception handling.

Class	Description
Actor<T>	A lightweight message-passing actor for concurrent state management.
ActorContext<T>	Context handle passed to context-aware actor handlers.
ActorOptions	Construction-time configuration for an Actor.
ActorOptions.Overflow	Policy applied when Actor.send(Object) is called on an actor whose bounded mailbox is full.
ActorOptions.StashOverflow	Policy applied when ActorContext.stash() is called and the actor's bounded stash is already at capacity.
Agent<T>	A thread-safe mutable-value container inspired by Clojure's agents and GPars' Agent.
AsyncChannel<T>	An asynchronous channel for inter-task communication with optional buffering.
AsyncScope	A structured concurrency scope that ensures all child tasks complete (or are cancelled) before the scope exits.
Awaitable<T>	Core abstraction for asynchronous computations in Groovy.
AwaitableAdapter	Service Provider Interface (SPI) for adapting third-party asynchronous types to Groovy's Awaitable abstraction and to iterables for for await loops.
AwaitableAdapterRegistry	Central registry for AwaitableAdapter instances.
AwaitResult<T>	Represents the outcome of an asynchronous computation that may have succeeded or failed.
BroadcastChannel<T>	A one-to-many broadcast channel where each value sent is delivered to all subscribers.
Cancellable	A handle for a scheduled action that can be called off before it fires (or that can have its further firings suppressed, in the case of a recurring schedule).
ChannelClosedException	Thrown when an AsyncChannel operation is attempted after the channel has been closed.
ChannelSelect	Selects the first available value from multiple AsyncChannels.
ChannelSelect.Result	The result of a ChannelSelect.select() operation, indicating which channel produced the value.
ConcurrentConfig	Central configuration for Groovy's concurrent and parallel features.
DataflowVariable<T>	A single-assignment variable for dataflow-style programming.
ParallelScope	Convenience API for running work within a pool-isolated AsyncScope.
Pool	A managed thread pool for parallel and concurrent operations.
ReactorHandler<T,R>	Context-aware handler for reactor actors.
StatefulHandler<S,T>	Context-aware handler for stateful actors.