Struct LockFreeBufferPool

pub struct LockFreeBufferPool { /* private fields */ }

Lock-free buffer pool for high-performance data processing

Implementations

impl LockFreeBufferPool

pub fn new(config: LockFreeBufferPoolConfig) -> Self

Create a new lock-free buffer pool with pre-allocated buffers

pub fn get_serialization_buffer(&self) -> Vec<u8>

Get a serialization buffer (lock-free)

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

Return a serialization buffer to the pool (lock-free)

pub fn get_compression_buffer(&self) -> Vec<u8>

Get a compression buffer (lock-free)

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

Return a compression buffer to the pool (lock-free)

pub fn get_simd_buffer(&self) -> VecSimd<f64x4>

Get a SIMD buffer (lock-free)

pub fn return_simd_buffer(&self, buffer: VecSimd<f64x4>)

Return a SIMD buffer to the pool (lock-free)

pub fn get_stats(&self) -> BufferPoolStats

Get pool statistics (lock-free reads)

pub fn reset_stats(&self)

Reset pool statistics (for benchmarking)

pub fn get_available_counts(&self) -> BufferCounts

Get approximate number of available buffers in each pool Note: This is approximate due to concurrent access

impl LockFreeBufferPool

pub fn get_serialization_buffer_guard(&self) -> BufferGuard<'_, Vec<u8>>

Get a serialization buffer with RAII guard

pub fn get_compression_buffer_guard(&self) -> BufferGuard<'_, Vec<u8>>

Get a compression buffer with RAII guard

pub fn get_simd_buffer_guard(&self) -> BufferGuard<'_, VecSimd<f64x4>>

Get a SIMD buffer with RAII guard

Trait Implementations

impl Send for LockFreeBufferPool

impl Sync for LockFreeBufferPool