Struct CacheIoWorker 

pub struct CacheIoWorker<Task, Output> { /* private fields */ }

Generic bounded background worker over opaque backend task and output types.

Implementations

impl<Task, Output> CacheIoWorker<Task, Output>

where Task: Send + 'static, Output: Clone + Send + 'static,

pub fn new( capacity: usize, thread_name: impl Into<String>, execute: fn(Task) -> Result<Output, String>, discard: fn(Output), ) -> Result<Self, CacheIoWorkerError>

Starts a bounded worker using statically dispatched task and cleanup functions.

pub fn with_nonblocking_drop(self) -> Self

Requests shutdown without joining from this handle’s destructor.

The worker owns in-flight tasks until they finish and discards queued tasks itself. Prepared submissions reject admission after shutdown.

pub fn prepare( &self, key: CacheIoOperationKey, task: Task, ) -> Result<CacheIoSubmission<Task, Output>, CacheIoWorkerError>

Prepares new work or joins an exact operation already owned by the worker.

pub fn retire(&self, ticket: &CacheIoTicket<Output>)

Releases exact-key ownership after task resources are safe to drop.

Trait Implementations

impl<Task, Output> Debug for CacheIoWorker<Task, Output>

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

Formats the value using the given formatter.

impl<Task, Output> Drop for CacheIoWorker<Task, Output>

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.