Struct CallbackPool 

pub struct CallbackPool { /* private fields */ }

The callback executor pool: three independent priority bands, each with its own bounded ring and worker thread(s). Port of the callbackQueue[] + callbackTask machinery in callback.c.

Dropping the pool shuts every band down and joins its workers (parity with callbackStop/callbackCleanup, callback.c:237-284).

Implementations

impl CallbackPool

pub fn new() -> Self

Build a pool with the C defaults: callbackQueueSize capacity per band (callback.c:51) and callbackThreadsDefault worker(s) per band (callback.c:66).

pub fn with_config(queue_size: usize, threads_per_priority: usize) -> Self

Build a pool with an explicit ring capacity and worker count per band. threads_per_priority is clamped to at least 1 (C callbackParallelThreads forces count >= 1, callback.c:171).

pub fn handle(&self) -> CallbackHandle

A cheap, clonable submission handle (see CallbackHandle).

pub fn request( &self, priority: CallbackPriority, cb: Callback, ) -> Result<(), CallbackError>

Enqueue cb on priority — convenience wrapper over CallbackHandle::request.

pub fn overflow_count(&self, priority: CallbackPriority) -> u64

Lifetime overflow count for a band — C queueOverflows (callback.c:57).

pub fn shutdown(&mut self)

Stop every band and join its workers — port of the shutdown half of callbackStop/callbackCleanup (callback.c:237-284). Idempotent.

Trait Implementations

impl Default for CallbackPool

fn default() -> Self

Returns the “default value” for a type.

impl Drop for CallbackPool

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.