Struct PoolTaker 

pub(crate) struct PoolTaker {
    pub(crate) pool: Arc<BufferPool>,
    pub(crate) local: Vec<Vec<u8>>,
}

Sole-consumer view over the shared BufferPool for the capture thread.

Refills are batched into a local stash, so the per-frame take is lock-free in the steady state, while returns from the delivery/Python side (AudioFrame drops) still go back through the shared pool. Only the capture thread owns a PoolTaker.

Fields

pool: Arc<BufferPool>

local: Vec<Vec<u8>>

Implementations

impl PoolTaker

pub(crate) fn new(pool: Arc<BufferPool>) -> Self

Wrap a shared pool with an empty local stash.

pub(crate) fn take(&mut self) -> Vec<u8>

Take one buf_size buffer: pop from the local stash, batch-refilling it from the shared pool (one lock) only when empty, and allocating fresh when both are empty.

pub(crate) fn put(&mut self, v: Vec<u8>)

Return a buffer on an error path without locking — it stays in the local stash.