Struct BufferPool 

pub struct BufferPool { /* private fields */ }

Lock-free buffer pool for reusing large I/O buffers Uses crossbeam’s SegQueue for lock-free operations

Implementations

impl BufferPool

pub fn new(buffer_size: BufferSize, max_pool_size: usize) -> Self

Create a new buffer pool with pre-allocated buffers

Arguments

• buffer_size - Size of each buffer in bytes (must be non-zero)
• max_pool_size - Maximum number of buffers to pool

All buffers are pre-allocated at creation time for optimal performance.

pub async fn get_buffer(&self) -> PooledBuffer

Get a buffer from the pool or create a new one (lock-free)

Returns a PooledBuffer that automatically returns to the pool when dropped. The buffer may contain old data, but this is safe because:

• Callers use AsyncRead which writes into the buffer
• They get back n bytes written and access only &buf[..n]
• Stale data beyond n is never accessed

pub async fn return_buffer(&self, buffer: Vec<u8>)

Return a buffer to the pool (lock-free)

Note: Usually not needed as PooledBuffer returns itself automatically on drop

Trait Implementations

impl Clone for BufferPool

fn clone(&self) -> BufferPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BufferPool

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

Formats the value using the given formatter.