threads_pool 0.2.6

This package provides an easy way to create and manage thread pools, so you don't have to.
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
48
49
50
51
52
53
54

extern crate threads_pool;

use std::collections::HashMap;
use std::thread;
use std::time::Duration;
use threads_pool::index_mode;

fn main() {
    let key_one = String::from("pool_one");
    let key_two = String::from("pool_two");
    let key_one_clone = key_one.clone();

    let mut pool_def = HashMap::with_capacity(2);
    pool_def.insert(key_one.clone(), 2);
    pool_def.insert(key_two.clone(), 2);

    index_mode::initialize(pool_def);

    let t1 = thread::spawn(move || {
        for num in 0..50 {
            let pool_key = key_one.clone();
            index_mode::run_with(pool_key, move || {
                println!("I'm in with key_one: {}", num);
                thread::sleep(Duration::from_millis(1));
            });
        }
    });

    let t2 = thread::spawn(move || {
        for num in 0..100 {
            let pool_key = key_two.clone();
            index_mode::run_with(pool_key, move || {
                println!("I'm in with key_two: {}", num);
                thread::sleep(Duration::from_millis(1));
            });

            if num > 80 {
                let pool_key = key_one_clone.clone();
                index_mode::run_with(pool_key, move || {
                    println!("I'm in with key_one: {}", num);
                    thread::sleep(Duration::from_micros(500));
                });
            }
        }
    });

    // make sure all jobs are properly sent
    t1.join().unwrap();
    t2.join().unwrap();

    println!("All jobs are sent!");

    index_mode::close();
}