Struct Reservoir 

pub struct Reservoir<M: Detach> { /* private fields */ }

A bounded, lock-free pool of detached connections shared by every thread.

Idle connections beyond a shard’s min_idle are detached into this queue, where any thread may claim them. Both ends are wait-free in the common case: ArrayQueue is a fixed-size ring, so parking and stealing never allocate and never take a lock. The only async step, Detach::attach, runs after the entry is already out of the queue.

Platform support

Only construct this where Detach is sound: io_uring and poll drivers treat attach as a no-op, so fds move freely. Under IOCP a handle is bound to one completion port for life. See Detach for the details.

Implementations

impl<M: Detach> Reservoir<M>

pub fn new(capacity: usize) -> Self

Creates a reservoir holding at most capacity connections.

pub fn capacity(&self) -> usize

The most connections this reservoir will hold.

pub fn len(&self) -> usize

Connections currently parked and claimable.

pub fn is_empty(&self) -> bool

True when nothing is parked.

Trait Implementations

impl<M: Detach> Debug for Reservoir<M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<M: Detach> Default for Reservoir<M>

fn default() -> Self

Returns the “default value” for a type.

impl<M: Detach> Exchange<M> for Reservoir<M>

fn park(&self, conn: M::Connection, meta: SlotMeta) -> Parked<M>

Offers an idle connection to other threads. Must not block.

async fn unpark(&self) -> Unparked<M>

Tries to claim a connection parked by another thread and reattach it to this one.

fn parked(&self) -> u64

Connections currently parked and claimable.

fn clear(&self)

Drops every parked connection. Called by Pool::close.