syncbox 0.2.4

Concurrency utilities for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

// TODO:
// - Consider splitting up the trait into Consume / Produce.
// - Break up SyncQueue from Queue
pub trait Queue<T: Send> {

    /// Retrieves and removes the head of this queue or returns None if the
    /// queue is empty.
    fn poll(&self) -> Option<T>;

    /// Returns true if the underlying data structure does not contain any
    /// elements.
    fn is_empty(&self) -> bool;

    fn offer(&self, e: T) -> Result<(), T>;
}

pub trait SyncQueue<T: Send> : Queue<T> {
    /// Retrieves and removes the head of this queue, waiting if necessary
    /// until an element becomes available.
    fn take(&self) -> T;

    fn put(&self, e: T);
}