Struct WorkerExecutor

pub struct WorkerExecutor { /* private fields */ }

A worker queue allows for the submission of work to be done in parallel.

Implementations

impl WorkerExecutor

pub fn new(pool_size: usize) -> Result<WorkerExecutor, Error>

pub fn join(self) -> Result<(), PayloadError<ProjectError>>

Waits for all workers to finish. Unlike the drop implementation, Calls finish_jobs.

pub fn submit<I>(&self, token: I) -> Result<WorkHandle<'_>, Error>

where I: Into<WorkToken>,

Forces all running tokens to end. Submit some work to the Worker Queue.

pub fn any_panicked(&self) -> bool

pub fn finish_jobs(&mut self) -> Result<(), Error>

Wait for all current jobs to finish.

pub fn queue(&self) -> WorkerQueue<'_>

Create a worker queue instance.

Trait Implementations

impl Drop for WorkerExecutor

fn drop(&mut self)

Executes the destructor for this type.