hooch 0.1.5

A small async runtime that's been bootlegged for my projects.
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

use std::sync::{Arc, Mutex};

use hooch::{pool::thread_pool::HoochPool, runtime::RuntimeBuilder};

#[test]
fn test_runs_on_pool_thread() {
    let handle_executor = RuntimeBuilder::new().num_workers(1).build();

    let blocking = Arc::new(Mutex::new(0));

    let blocking_clone = Arc::clone(&blocking);

    handle_executor.run_blocking(async move {
        let (tx, rx) = std::sync::mpsc::sync_channel(1);
        let block_fn = move || {
            *blocking_clone.lock().unwrap() += 1;
            tx.send(()).unwrap();
        };

        let hp = HoochPool::get();

        hp.execute(Box::new(block_fn));
        rx.recv().unwrap()
    });

    assert!(*blocking.lock().unwrap() == 1)
}