Struct task_kit::runner::Runner

pub struct Runner { /* fields omitted */ }

A thread pool for executing tasks.

Runner contains a pool of workers, each with it's own thread. As tasks are given to the runner to be executed, the workers execute these tasks. In order to prevent idle workers when there is work to be done, the Runner implement's the work stealling model for parallelism. Idle workers will steal tasks from their siblings in order keep the load distributed, and prevent idle cores.

Methods

impl Runner

fn new() -> Self

fn with_worker_count(n: usize) -> Self

fn run<T>(&mut self, task: T) where
    T: Executable + 'static, 

fn run_all<T>(&mut self, tasks: Vec<T>) where
    T: Executable + 'static, 

fn finish(self)

Trait Implementations

impl Debug for Runner

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.