job-pool 0.6.0

Thread Pool
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use std::sync::mpmc;

pub fn sync_channel<T>(bound: usize) -> (SenderWrapper<T>, ReceiverWrapper<T>) {
    let (s,r) = mpmc::sync_channel(bound);
    let s = SenderWrapper(s);
    let r = ReceiverWrapper(r);
    (s,r)
}

pub fn channel<T>() -> (SenderWrapper<T>, ReceiverWrapper<T>) {
    let (s,r) = mpmc::channel();
    let s = SenderWrapper(s);
    let r = ReceiverWrapper(r);
    (s,r)
}

pub struct SenderWrapper<T>(mpmc::Sender<T>);

impl<T> SenderWrapper<T> {
    pub fn send(&self, t: T) -> std::result::Result<(),mpmc::SendError<T>> {
        self.0.send(t)
    }
}

pub struct ReceiverWrapper<T>(pub mpmc::Receiver<T>);

impl<T> Clone for ReceiverWrapper<T> {
    fn clone(&self) -> Self {
        Self(self.0.clone())
    }
}

impl<T> ReceiverWrapper<T> {
    pub fn recv(&self) -> Result<T, mpmc::RecvError> {
        self.0.recv()
    }
}