distribuidos_sync 1.2.0

Sync common utils using standard library
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use std::sync::{mpsc, Arc, Mutex};

pub enum Message<T>
where
    T: Send,
{
    NewJob(T),
    Terminate,
}

#[derive(Debug)]
pub enum QueueError<T> {
    Full(T),
}

pub type MessageSender<T> = mpsc::Sender<Message<T>>;
pub type MessageSyncSender<T> = mpsc::SyncSender<Message<T>>;
pub type MessageReceiver<T> = mpsc::Receiver<Message<T>>;
pub type SharedMessageReceiver<T> = Arc<Mutex<MessageReceiver<T>>>;