Struct FaaArrayQueue 

pub struct FaaArrayQueue<T: Send> { /* private fields */ }

a lock free mpmc queue

Examples

use faa_array_queue::FaaArrayQueue;

let queue = FaaArrayQueue::<usize>::default();

Implementations

impl<T: Send> FaaArrayQueue<T>

pub fn enqueue(&self, item: T)

add an item to the tail of the queue

Arguments

• item - the item to add

Examples

use faa_array_queue::FaaArrayQueue;

let queue = FaaArrayQueue::<usize>::default();
queue.enqueue(1337);
assert!(queue.dequeue().unwrap() == 1337);

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

remove an item from the head of the queue

Arguments

• return - Some item removed or None if the queue is empty

Examples

use faa_array_queue::FaaArrayQueue;

let queue = FaaArrayQueue::<usize>::default();
assert!(queue.dequeue().is_none());

Trait Implementations

impl<T: Send> Default for FaaArrayQueue<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Send> Drop for FaaArrayQueue<T>

fn drop(&mut self)

Executes the destructor for this type.