Struct CpuWorker 

pub struct CpuWorker { /* private fields */ }

A single-threaded background worker that executes closures in order.

let worker = CpuWorker::new();
worker.submit(|| {
    save_checkpoint(&snapshot, "model.pt").unwrap();
});
// GPU training continues immediately
worker.finish(); // blocks until all queued work completes

Implementations

impl CpuWorker

pub fn new() -> Self

Spawn the background worker thread.

pub fn submit<F: FnOnce() + Send + 'static>(&self, f: F)

Submit a closure to run on the background thread.

pub fn is_idle(&self) -> bool

Check whether the worker is idle (not currently executing a task).

Useful for skip-if-busy semantics: only submit a new checkpoint if the previous one has finished.

pub fn finish(&mut self)

Drop the sender and join the worker thread, blocking until all queued tasks have completed.

Trait Implementations

impl Default for CpuWorker

fn default() -> Self

Returns the “default value” for a type.

impl Drop for CpuWorker

fn drop(&mut self)

Executes the destructor for this type.