Crate slave_pool

Simple thread pool

Usage

use slave_pool::ThreadPool;
const SECOND: core::time::Duration = core::time::Duration::from_secs(1);

static POOL: ThreadPool = ThreadPool::new();

POOL.set_threads(8); //Tell how many threads you want

let mut handles = Vec::new();
for idx in 0..8 {
    handles.push(POOL.spawn_handle(move || {
        std::thread::sleep(SECOND);
        idx
    }));
}

POOL.set_threads(0); //Tells to shut down threads

for (idx, handle) in handles.drain(..).enumerate() {
    assert_eq!(handle.wait().unwrap(), idx) //Even though we told  it to shutdown all threads, it is going to finish queued job first
}

let handle = POOL.spawn_handle(|| {});
assert!(handle.wait_timeout(SECOND).is_err()); // All are shutdown now

POOL.set_threads(1); //But let's add one more

assert!(handle.wait().is_ok());

let handle = POOL.spawn_handle(|| panic!("Oh no!")); // We can panic, if we want

assert!(handle.wait().is_err()); // In that case we'll get error, but thread will be ok

let handle = POOL.spawn_handle(|| {});

POOL.set_threads(0);

assert!(handle.wait().is_ok());

Structs

JobHandle

Handle to the job, allowing to await for it to finish

ThreadPool

Thread pool that allows to change number of threads at runtime.

Enums

JoinError

Describes possible reasons for join to fail