Struct PoolJob 

pub struct PoolJob { /* private fields */ }

Type-erased pool job with separate detached and cancellable forms.

Implementations

impl PoolJob

pub fn new( run: Box<dyn FnOnce() + Send + 'static>, cancel: Box<dyn FnOnce() + Send + 'static>, ) -> Self

Creates a custom cancellable job with no acceptance callback.

Higher-level services that maintain their own task state usually want Self::with_accept instead, so they can publish acceptance only after the backing pool has accepted the job.

Parameters

• run - Callback executed when a worker starts this job.
• cancel - Callback executed if the accepted job is cancelled before it starts.

Returns

A custom type-erased job accepted by thread pools.

pub fn with_accept( accept: Box<dyn FnOnce() + Send + 'static>, run: Box<dyn FnOnce() + Send + 'static>, cancel: Box<dyn FnOnce() + Send + 'static>, ) -> Self

Creates a custom cancellable job with an acceptance callback.

The pool invokes accept exactly once after the submission crosses the acceptance boundary. If submission is rejected before acceptance, neither accept, run, nor cancel is invoked.

Parameters

• accept - Callback invoked once the pool accepts the job.
• run - Callback executed when a worker starts this job.
• cancel - Callback executed if the accepted job is cancelled before it starts.

Returns

A custom type-erased job accepted by thread pools.