Struct LockFreePool 

pub struct LockFreePool<T: Send + 'static> { /* private fields */ }

Implementations

impl<T: Send + 'static> LockFreePool<T>

pub fn new( create: CreateFn<T>, validate: ValidateFn<T>, config: &PoolConfig, ) -> Self

Create a new lock-free pool with the given factory and config.

All memory for the idle queue is pre-allocated at construction (max_size slots). No heap allocation occurs on the hot path.

pub async fn acquire(&self) -> Result<PooledConnection<T>, PoolError>

Acquire a connection from the pool.

Fast path (common case, lock-free)

1. Pop from idle queue (CAS loop, no syscall)
2. Validate the connection (async SELECT 1)
3. Return as PooledConnection

Slow path (pool empty, not at capacity)

4. CAS-increment size, create connection, return

Wait path (pool empty, at capacity)

5. Park on Notify with timeout, retry

pub fn close(&self)

pub fn is_closed(&self) -> bool

pub fn status(&self) -> PoolStatus

pub fn max_size(&self) -> u32

Trait Implementations

impl<T: Send + 'static> Clone for LockFreePool<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Send + 'static> Send for LockFreePool<T>

impl<T: Send + 'static> Sync for LockFreePool<T>