Struct AsyncPool 

pub struct AsyncPool { /* private fields */ }

A priority-queue–driven allocation pool with memory pressure callbacks.

Implementations

impl AsyncPool

pub fn new(config: PoolConfig) -> Self

Create a new AsyncPool from the given configuration.

pub fn enqueue( &mut self, req: AsyncAllocRequest, ) -> Result<RequestHandle, AllocError>

Submit an allocation request to the queue.

Returns Err(AllocError::PoolFull) if the queue is at capacity.

pub fn process_queue( &mut self, max_allocations: usize, ) -> Vec<(RequestHandle, AllocationId)>

Process up to max_allocations pending requests, highest-priority first.

Returns a Vec of (RequestHandle, AllocationId) pairs for every request that completed successfully. Failed requests are recorded in the result map and can be queried via get_result.

pub fn is_ready(&self, handle: RequestHandle) -> bool

Return true if the given request has been processed (successfully or not).

pub fn get_result(&self, handle: RequestHandle) -> Option<AllocationId>

Return the AllocationId for a successfully completed request, or None if the request is still pending or failed.

pub fn get_error(&self, handle: RequestHandle) -> Option<&AllocError>

Return the error for a failed request, or None if pending / successful.

pub fn register_pressure_callback( &mut self, threshold: f64, cb: Box<dyn Fn(f64) + Send>, )

Register a callback to be fired when the pool fragmentation exceeds threshold.

The callback receives the current fragmentation score.

pub fn check_pressure(&self)

Evaluate all registered pressure thresholds and fire callbacks if exceeded.

pub fn throughput_ops_per_sec(&mut self) -> f64

Return the allocation throughput in operations per second since the last call.

pub fn avg_alloc_latency_ns(&self) -> f64

Return the average allocation latency in nanoseconds over the last min(n_completed, 256) operations.

pub fn stats(&self) -> AllocationStats

Return a snapshot of the arena statistics.

pub fn pending_count(&self) -> usize

Return the number of pending (not-yet-processed) requests.

pub fn free(&mut self, id: AllocationId) -> Result<(), AllocError>

Free an allocation by id in the underlying arena.

pub fn arena(&self) -> &ArenaAllocator

Access the underlying arena (read-only).

pub fn arena_mut(&mut self) -> &mut ArenaAllocator

Access the underlying arena (mutable).