Struct pawawwewism::Worker

pub struct Worker<I: Send + 'static> { /* private fields */ }

A handle to a worker thread that processes messages of type I.

This type enforces structured concurrency: When it’s dropped, the thread will be signaled to exit and the thread will be joined. If the thread has panicked, the panic will be forwarded to the thread dropping the Worker.

Implementations

impl Worker<()>

pub fn builder() -> WorkerBuilder

Returns a builder that can be used to configure and spawn a Worker.

impl<I: Send + 'static> Worker<I>

pub fn send(&mut self, msg: I)

Sends a message to the worker thread.

If the worker’s channel capacity is exhausted, this will block until the worker is available to accept the message.

If the worker has panicked, this will propagate the panic to the calling thread.

Trait Implementations

impl<I: Send + 'static> Drop for Worker<I>

fn drop(&mut self)

Executes the destructor for this type.