qubit-thread-pool 0.7.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::time::Duration;

use qubit_thread_pool::{
    ExecutorService,
    ThreadPool,
};

#[test]
fn test_thread_pool_config_is_reflected_by_builder_and_stats() {
    let pool = ThreadPool::builder()
        .core_pool_size(1)
        .maximum_pool_size(3)
        .queue_capacity(8)
        .thread_name_prefix("config-check")
        .keep_alive(Duration::from_millis(25))
        .allow_core_thread_timeout(true)
        .build()
        .unwrap();
    let stats = pool.stats();

    assert_eq!(1, stats.core_pool_size);
    assert_eq!(3, stats.maximum_pool_size);
    assert_eq!(0, pool.queued_count());
    pool.shutdown();
    pool.wait_termination();
}