tom_thread_pool 0.1.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

use std::sync::mpsc::{self, Receiver, Sender};
use std::thread;
use std::time::Duration;
use thread_pool::ThreadPool;

fn main() {
    let (tx, rx) = mpsc::channel();
    let pool = ThreadPool::new(2);
    let mut i: i128 = 0;
    let main_receiver = receiver(rx);
    
    while true {
        let j = i.clone();
        let tx1 = tx.clone();
        let mut end = false;
        if i > 2 {
            end = true;
        }
        pool.execute(move || {
            handle_tx(j, end, tx1);
        });
        i += 1;
        thread::sleep(Duration::from_millis(1000));
        if i > 3{
            break;
        }
    }
    main_receiver.join().unwrap();
}