Struct FastQueue 

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

A fast lock-free single-producer, single-consumer queue

Implementations

impl<T> FastQueue<T>

pub fn new(capacity: usize) -> (Producer<T>, Consumer<T>)

Creates a SPSC queue with the given capacity. The allocated capacity may be higher.

Capacity is rounded to the next power of two. The minimum allocated capacity is 2.

Example

use fq::FastQueue;
struct Message {
    from: String,
    value: usize,
}
let (producer, consumer) = FastQueue::<Message>::new(2);

Trait Implementations

impl<T> Drop for FastQueue<T>

fn drop(&mut self)

Drops all elements in the queue. This will only drop the elements, not the queue itself.

impl<T: Send> Send for FastQueue<T>

impl<T: Send> Sync for FastQueue<T>