Struct UnboundedEnqueueHandle

pub struct UnboundedEnqueueHandle<'a, T> { /* private fields */ }

A enqueue handle to an UnboundedQueue, allowing for bulk enqueues efficiently. Internally, the unbounded queue manages the queue of bounded queues with hazard pointers to avoid the ABA problem, this allows minimizing the creation of these hazard pointers.

Example

use lfqueue::UnboundedQueue;

let queue = UnboundedQueue::<usize>::new();
let mut handle = queue.enqueue_handle();
handle.enqueue(3);

Implementations

impl<'a, T> UnboundedEnqueueHandle<'a, T>

where T: Send + Sync,

pub fn enqueue(&mut self, item: T)

Enqueues an item on the underlying queue.

Example

use lfqueue::{UnboundedEnqueueHandle, UnboundedQueue};

let queue = UnboundedQueue::<usize>::new();
let mut handle = queue.enqueue_handle();
handle.enqueue(3);