Struct swap::worker::Worker

pub struct Worker<T> {
    pub channel: Arc<Channel<T>>,
    handles: Vec<JoinHandle<()>>,
}

Multi thread based worker executing a single type Task.

See the doc of Channel as well for the behaviors of it.

Fields

channel: Arc<Channel<T>>

Shared Channel with the worker threads.

handles: Vec<JoinHandle<()>>

Implementations

impl<T: Task + Send + 'static> Worker<T>

pub fn new(len_channel: usize, n_workers: usize) -> Self

Spawns the numbers of worker threads.

fn worker_thread(context: Arc<Channel<T>>)

pub fn close(self)

Closes the channel and wait for worker threads shutdown.

This also waits for all the tasks in the channel to be executed.