Struct BackgroundPrefetchWorker 

pub struct BackgroundPrefetchWorker { /* private fields */ }

One bounded background prefetch worker with exact cancellation and configurable shutdown.

Implementations

impl BackgroundPrefetchWorker

pub fn new<F>( capacity: usize, thread_name: impl Into<String>, operation: F, ) -> Result<Self, BackgroundPrefetchWorkerError>

where F: Fn(&OffloadUnitId) -> Result<(), String> + Send + Sync + 'static,

Starts a named worker which executes one backend-owned operation at a time.

pub fn with_nonblocking_drop(self) -> Self

Requests shutdown without joining when this handle is dropped.

The worker retains its operation and lifecycle state until in-flight work returns. Queued work is cancelled by that worker; callers needing a synchronous fence can still explicitly call Self::cancel.

pub fn submit( &self, id: &OffloadUnitId, resident: bool, ) -> Result<(), BackgroundPrefetchWorkerError>

Admits or coalesces one operation after the backend reports current residency.

pub fn wait( &self, id: &OffloadUnitId, ) -> Result<PrefetchDemandResolution<String>, BackgroundPrefetchWorkerError>

Waits for background ownership to resolve and consumes its exact result.

pub fn cancel(&self) -> Result<(), BackgroundPrefetchWorkerError>

Cancels queued work, fences in-flight work, and returns its first failure.

pub fn report( &self, ) -> Result<BackgroundPrefetchReport, BackgroundPrefetchWorkerError>

Returns an immutable lifecycle and backpressure report.

pub fn wait_idle(&self) -> Result<(), BackgroundPrefetchWorkerError>

Waits until all admitted work reaches a terminal state.

Trait Implementations

impl Drop for BackgroundPrefetchWorker

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.