Struct WorkQueue 

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

Thread-safe work queue

This matches the C++ threadsafe_queue class that wraps std::queue with a mutex for thread-safe access.

Implementations

impl<T> WorkQueue<T>

pub fn new() -> Self

Create a new empty work queue

pub fn push(&self, value: T)

Push a value onto the queue

pub fn try_pop(&self) -> Option<T>

Try to pop a value from the queue

Returns true if a value was popped, false if queue is empty

pub fn size(&self) -> usize

Get the current size of the queue

pub fn is_empty(&self) -> bool

Check if the queue is empty

Trait Implementations

impl<T> Clone for WorkQueue<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Default for WorkQueue<T>

fn default() -> Self

Returns the “default value” for a type.