trax 0.0.1

Application Monitoring and Error Tracking Software
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

use anyhow::Result;
use dotenv::dotenv;
use std::thread;
use std::time::Duration;
use threadpool::ThreadPool;

fn main() -> Result<()> {
    dotenv().ok();

    let pool = ThreadPool::new(4);

    let (sender, receiver) = std::sync::mpsc::channel();

    for _ in 0..4 {
        let sender = sender.clone();
        pool.execute(move || {
            thread::sleep(Duration::from_secs(1));
            sender.send("Hello from thread pool").unwrap();
        });
    }

    loop {
        let msg = receiver.recv().unwrap();
        println!("{}", msg);
    }

    // Ok(())
}