eve.rt.channel.dynamic

Dynamic-resize channel for the EVE runtime.

A dynamic channel grows up to a configurable maximum capacity and shrinks back toward the initial capacity when items are consumed. This balances memory usage against burst tolerance.

struct ChannelDynamic

Types 1

structChannelDynamic(T)

Dynamic-resize channel that grows on demand and shrinks on consume.

The buffer starts at initialCapacity and grows up to maxCapacity. When the buffer drains below a shrink threshold, it compacts back toward initialCapacity.

Fields

private T[] buffer

private size_t head

private size_t tail

private size_t count

private size_t capacity_

private size_t initialCapacity_

private size_t maxCapacity_

private bool closed_

private Mutex mutex

private Condition notEmpty

private Condition notFull

Methods

private void grow() @trusted nothrow

private void shrink() @trusted nothrow

ChannelStatus blockingSend(T value) @trustedSend a value, blocking if at max capacity.

ChannelStatus trySend(T value) @trustedTry to send without blocking.

ChannelStatus blockingReceive(out T value) @trustedReceive a value, blocking if empty.

ChannelStatus tryReceive(out T value) @trustedTry to receive without blocking.

ChannelStatus trySend(T value, CancelToken token) @trusted

ChannelStatus tryReceive(out T value, CancelToken token) @trusted

ChannelStatus blockingSend(T value, CancelToken token) @trusted

ChannelStatus blockingReceive(out T value, CancelToken token) @trusted

void close() @trusted

bool isClosed() @property @trusted

size_t length() @property @trusted

size_t capacity() @property const pure @safe nothrow @nogc

bool empty() @property @trusted

Constructors

this()

this(size_t initialCapacity, size_t maxCapacity)Construct a dynamic channel.