qubit-thread-pool 0.5.0

Dynamic and fixed thread pool executor services for Qubit Rust libraries
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

use std::io;

use qubit_thread_pool::{
    ExecutorService,
    ThreadPool,
};

#[test]
fn test_worker_runtime_runs_job_on_named_worker_thread() {
    let pool = ThreadPool::builder()
        .core_pool_size(1)
        .maximum_pool_size(1)
        .thread_name_prefix("runtime-check")
        .build()
        .unwrap();
    let name = pool
        .submit_callable(|| {
            Ok::<_, io::Error>(std::thread::current().name().unwrap_or_default().to_owned())
        })
        .unwrap()
        .get()
        .unwrap();

    assert!(name.starts_with("runtime-check-"));
    pool.shutdown();
}