Struct WorkQueue

pub struct WorkQueue { /* private fields */ }

A running work queue thread.

Panic

Allowing a work queue to drop will result in a panic. There are two ways to handle this, depending on whether the WorkQueue is in a Box, or an Arc:

// Leak a work queue in an Arc.
let wq = Arc::new(WorkQueueBuilder::new().start(...));
// If the Arc is used after this:
let _ = Arc::into_raw(wq.clone());
// If the Arc is no longer needed:
let _ = Arc::into_raw(wq);

// Leak a work queue in a Box.
let wq = Box::new(WorkQueueBuilder::new().start(...));
let _ = Box::leak(wq);

Trait Implementations

impl Drop for WorkQueue

fn drop(&mut self)

Executes the destructor for this type.

impl Send for WorkQueue

Work queues can be referenced from multiple threads, and thus are Send and Sync.

impl Sync for WorkQueue