Struct WorkQueue 

pub struct WorkQueue { /* private fields */ }

Global work queue for task injection.

Implementations

impl WorkQueue

pub fn new() -> Self

Create a new work queue.

pub fn push(&self, task: Task)

Push a task to the global queue.

pub fn push_batch(&self, tasks: Vec<Task>)

Push multiple tasks to the global queue.

pub fn steal_global(&self) -> Option<Task>

Steal a task from the global queue.

pub fn injector(&self) -> &Injector<Task>

Get the global injector reference.

pub fn register_worker(&self)

Register a new worker.

pub fn unregister_worker(&self)

Unregister a worker.

Trait Implementations

impl Default for WorkQueue

fn default() -> Self

Returns the “default value” for a type.