Struct Enqueuer 

pub struct Enqueuer<T: Task> { /* private fields */ }

A handle to enqueue tasks for a Worker.

Worker::enqueue() / enqueue_one() is the most convenient way to enqueue new tasks, but can be troublesome if the Worker is not directly available or borrowed elsewhere. An Enqueuer is a dedicated handle to the Worker for enqueueing new tasks, and can help work around such issues. Most notably, it can be used while the worker is asleep. It can be accessed via Worker::enqueuer() (which returns &Rc<Enqueuer<T>>).

Implementations

impl<T: Task> Enqueuer<T>

pub fn add(&self, task: T)

Enqueue a task.

If the worker is asleep, it will be woken up.

Panics

Panics if this is called while the enqueuer is borrowed, e.g. it is within a call to Enqueuer::extend().

pub fn extend(&self, tasks: impl IntoIterator<Item = T>)

Enqueue a set of tasks.

If the worker is asleep, it will be woken up.

Panics

Panics if this is called while the enqueuer is borrowed, e.g. it is within a(nother) call to Enqueuer::extend().

Trait Implementations

impl<T: Task> Drop for Enqueuer<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<T: Task> Extend<T> for &Enqueuer<T>

fn extend<I: IntoIterator<Item = T>>(&mut self, tasks: I)

Enqueue a set of tasks.

This is equivalent to (and is defined as) Enqueuer::extend().

If the worker is asleep, it will be woken up.

Panics

Panics if this is called while the enqueuer is borrowed, e.g. it is within a(nother) call to Enqueuer::extend().

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)

Extends a collection with exactly one element.

fn extend_reserve(&mut self, additional: usize)

🔬This is a nightly-only experimental API. (extend_one)

Reserves capacity in a collection for the given number of additional elements.