cram 0.1.2

Cram realy awesome middleware
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
38
39
40
41
42
43
44
45
46
47

use super::{ThreadMessage,ThreadPool};

use crossbeam::crossbeam_channel::{unbounded,Sender};


impl ThreadPool{
    pub fn new( num_threads : usize) -> ThreadPool{
        
        let (s,r) = unbounded();
        
        let pool = threadpool::ThreadPool::new(num_threads);
        
        for _ in 0..num_threads{
        
            let receiver = r.clone();
        
            pool.execute(move || loop {
                
                let th_message : ThreadMessage;
               
                match receiver.recv() {
                    Ok(val) => th_message = val,
                    Err(_e) => break,
                }
                if th_message.is_stateless(){
                    let info = th_message.get_stateless().unwrap();
                    (info.fun)(info.message); 
    
                }else{
                    let info = th_message.get_stateful().unwrap();
                    let mut f = info.fun;
                    f(info.message); 
                    info.sender.send((info.label, f)).unwrap();
                }
            });
        }

        ThreadPool{
            input_channel : s,
        } 
    }

    pub fn get_sender(&self) -> Sender<ThreadMessage>{
        self.input_channel.clone()
    }

}