Package groovy.concurrent

Interface AsyncChannel<T>

Type Parameters:
T - the payload type
All Superinterfaces:
Iterable<T>
All Known Implementing Classes:
DefaultAsyncChannel
public interface AsyncChannel<T> extends Iterable<T>
An asynchronous channel for inter-task communication with optional buffering.

A channel coordinates producers and consumers without exposing explicit locks or shared mutable state, following the CSP (Communicating Sequential Processes) paradigm popularized by Go's channels.

Channels support both unbuffered (rendezvous) and buffered modes:

  • Unbuffered — create() or create(0). Each send suspends until a matching receive arrives.
  • Buffered — create(n). Values are enqueued until the buffer fills, then senders suspend.

Channels implement Iterable, so they work with for await and regular for loops — iteration yields received values until the channel is closed and drained: 


 def ch = AsyncChannel.create(2)
 async { ch.send('a'); ch.send('b'); ch.close() }
 for await (item in ch) {
     println item   // prints 'a', then 'b'
 }
Since:
6.0.0
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    close()
    Closes this channel.
    static <T> AsyncChannel<T>
    create()
    Creates an unbuffered (rendezvous) channel.
    static <T> AsyncChannel<T>
    create(int capacity)
    Creates a channel with the specified buffer capacity.
    int
    getBufferedSize()
    Returns the number of values currently buffered.
    int
    getCapacity()
    Returns this channel's buffer capacity.
    boolean
    isClosed()
    Returns true if this channel has been closed.
    Awaitable<T>
    receive()
    Receives the next value from this channel.
    Awaitable<Void>
    send(T value)
    Sends a value through this channel.

    Methods inherited from interface java.lang.Iterable

    forEach, iterator, spliterator

  • Method Details

    • create

      static <T> AsyncChannel<T> create()
      Creates an unbuffered (rendezvous) channel.

    • create

      static <T> AsyncChannel<T> create(int capacity)
      Creates a channel with the specified buffer capacity.
      Parameters:
      capacity - the maximum buffer size; 0 for unbuffered

    • getCapacity

      int getCapacity()
      Returns this channel's buffer capacity.

    • getBufferedSize

      int getBufferedSize()
      Returns the number of values currently buffered.

    • isClosed

      boolean isClosed()
      Returns true if this channel has been closed.

    • send

      Awaitable<Void> send(T value)
      Sends a value through this channel.

      The returned Awaitable completes when the value has been delivered to a receiver or buffered. Sending to a closed channel fails immediately with ChannelClosedException.

      Parameters:
      value - the value to send; must not be null
      Returns:
      an Awaitable that completes when the send succeeds
      Throws:
      NullPointerException - if value is null

    • receive

      Awaitable<T> receive()
      Receives the next value from this channel.

      The returned Awaitable completes when a value is available. Receiving from a closed, empty channel fails with ChannelClosedException.

      Returns:
      an Awaitable that yields the next value

    • close

      boolean close()
      Closes this channel. Idempotent.

      Buffered values remain receivable. Pending senders fail with ChannelClosedException. After all buffered values are drained, subsequent receives also fail.

      Returns:
      true if this call actually closed the channel