Struct CreditPool 

pub struct CreditPool { /* private fields */ }

A pool of credits shared between producer and consumer.

Credits are atomically tracked; producers consume credits when emitting items and consumers release credits as they process those items.

Implementations

impl CreditPool

pub fn new(capacity: i64) -> Self

Create a pool with the given initial (and maximum) capacity.

pub fn try_acquire(&self, n: i64) -> bool

Try to acquire n credits (non-blocking).

Returns true if the credits were successfully acquired, false if the pool does not currently hold enough credits (backpressure signal).

pub fn release(&self, n: i64)

Release n credits back to the pool (consumer-side).

The pool is clamped to its capacity to prevent over-replenishment.

pub fn available(&self) -> i64

Number of credits currently available.

pub fn capacity(&self) -> i64

Maximum credits this pool can hold.

pub fn utilization(&self) -> f64

Utilization fraction: 0.0 when pool is full (nothing consumed), 1.0 when completely empty (maximum backpressure).

Trait Implementations

impl Clone for CreditPool

fn clone(&self) -> CreditPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CreditPool

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

Formats the value using the given formatter.