task_queue

The implementation of the thread pool for Rust.

Library supports dynamic control over the number of threads.

Documentation

Usage

Add this to your Cargo.toml:

[dependencies]
task_queue = "0.0.7"

and this to your crate root:

extern crate task_queue;

Example

extern crate task_queue;

let mut queue = task_queue::TaskQueue::new();

for _ in 0..10 {
  queue.enqueue(|| {
    println!("Hi from pool")
  }).unwrap();
}

queue.stop_wait();