Trait PoolTask 

pub trait PoolTask: Send + Sync {
    // Required method
    fn execute(&self, ctx: &InternalTaskContext) -> Result<()>;

    // Provided methods
    fn priority(&self) -> Priority { ... }
    fn name(&self) -> &str { ... }
    fn can_retry(&self) -> bool { ... }
    fn max_retries(&self) -> usize { ... }
}

Trait for tasks that can be executed by the worker pool

Required Methods

fn execute(&self, ctx: &InternalTaskContext) -> Result<()>

Execute the task

Provided Methods

fn priority(&self) -> Priority

Get the priority of this task

fn name(&self) -> &str

Get a name/description for this task for debugging

fn can_retry(&self) -> bool

Whether this task can be retried on failure

fn max_retries(&self) -> usize

Maximum number of retries if can_retry is true

Implementors

impl<F> PoolTask for InternalClosureTask<F>

where F: Fn(&InternalTaskContext) -> Result<()> + Send + Sync,