Struct crossbeam_deque::Worker[][src]

pub struct Worker<T> { /* fields omitted */ }
Expand description

A worker queue.

This is a FIFO or LIFO queue that is owned by a single thread, but other threads may steal tasks from it. Task schedulers typically create a single worker queue per thread.

Examples

A FIFO worker:

use crossbeam_deque::{Steal, Worker};

let w = Worker::new_fifo();
let s = w.stealer();

w.push(1);
w.push(2);
w.push(3);

assert_eq!(s.steal(), Steal::Success(1));
assert_eq!(w.pop(), Some(2));
assert_eq!(w.pop(), Some(3));

A LIFO worker:

use crossbeam_deque::{Steal, Worker};

let w = Worker::new_lifo();
let s = w.stealer();

w.push(1);
w.push(2);
w.push(3);

assert_eq!(s.steal(), Steal::Success(1));
assert_eq!(w.pop(), Some(3));
assert_eq!(w.pop(), Some(2));

Implementations

Creates a FIFO worker queue.

Tasks are pushed and popped from opposite ends.

Examples

use crossbeam_deque::Worker;

let w = Worker::<i32>::new_fifo();

Creates a LIFO worker queue.

Tasks are pushed and popped from the same end.

Examples

use crossbeam_deque::Worker;

let w = Worker::<i32>::new_lifo();

Creates a stealer for this queue.

The returned stealer can be shared among threads and cloned.

Examples

use crossbeam_deque::Worker;

let w = Worker::<i32>::new_lifo();
let s = w.stealer();

Returns true if the queue is empty.

use crossbeam_deque::Worker;

let w = Worker::new_lifo();

assert!(w.is_empty());
w.push(1);
assert!(!w.is_empty());

Pushes a task into the queue.

Examples

use crossbeam_deque::Worker;

let w = Worker::new_lifo();
w.push(1);
w.push(2);

Pops a task from the queue.

Examples

use crossbeam_deque::Worker;

let w = Worker::new_fifo();
w.push(1);
w.push(2);

assert_eq!(w.pop(), Some(1));
assert_eq!(w.pop(), Some(2));
assert_eq!(w.pop(), None);

Trait Implementations

Formats the value using the given formatter. Read more

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Performs the conversion.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.