Struct Worker

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

Implementations

impl<T> Worker<T>

pub fn new() -> Worker<T>

Creates a new Worker queue.

Examples

use swap_queue::Worker;

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

pub fn auto_batched(batch_size: usize) -> Worker<T>

Creates an auto-batched Worker queue with fixed-length buffers. At capacity, the buffer is swapped out and ownership taken by the returned Stealer. Batch size must be a power of 2

Examples

use swap_queue::Worker;

let w = Worker::<i32>::auto_batched(64);

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

Write to the next slot, swapping buffers as necessary and returning a Stealer at the start of a new batch

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> Drop for Worker<T>

fn drop(&mut self)

Executes the destructor for this type.

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