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

use qubit_thread_pool::{
    ExecutorService,
    ExecutorServiceLifecycle,
    FixedThreadPool,
};

#[test]
fn test_fixed_thread_pool_lifecycle_reports_shutdown_and_termination() {
    let pool = FixedThreadPool::new(1).expect("fixed thread pool should build");

    assert!(!pool.is_not_running());
    assert_eq!(pool.lifecycle(), ExecutorServiceLifecycle::Running);
    pool.shutdown();
    assert!(pool.is_not_running());
    pool.wait_termination();

    assert!(pool.is_terminated());
    assert_eq!(pool.lifecycle(), ExecutorServiceLifecycle::Terminated);
}