Struct swap_queue::Worker

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

A thread-owned worker queue that writes to a swappable buffer using atomic slotting

Examples

use swap_queue::Worker;

let w = Worker::new();
let s = w.push(1).unwrap();
w.push(2);
w.push(3);
assert_eq!(s.take_blocking(), vec![1, 2, 3]);

let s = w.push(4).unwrap();
w.push(5);
w.push(6);
let batch: Vec<_> = s.into();
assert_eq!(batch, vec![4, 5, 6]);

Implementations

impl<T> Worker<T>

pub fn new() -> Worker<T>

Creates a new Worker queue.

Tasks are pushed and the underlying buffer is swapped and converted back into a Vec<T> when taken by a stealer.

Examples

use swap_queue::Worker;

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

pub fn push(&self, task: T) -> Option<Stealer<T>>

Push a task to the queue and returns a Stealer if empty

Trait Implementations

impl<T> Debug for Worker<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for Worker<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Send> Send for Worker<T>