task_pool

Crates.io Docs.rs

task_pool offers a flexible abstraction for composing and distributing work within a fixed hardware threadpool. To that end, it offers the following features:

Usage

To use task_pool, there are three steps:

  1. Creating and initializing WorkProvider instances (such as a queue or chain of multiple queues)
  2. Creating a hardware TaskPool which consumes those instances
  3. Spawning high-level tasks on the WorkProviders which are handled by the threadpool

The following example shows these steps in action:

```rust // 1. Create a queue from which we can spawn tasks let queue = TaskQueue::::default();

// 2. Create a threadpool that draws from the provided queue. Forget the threadpool so that it runs indefinitely. TaskPool::new(queue.clone(), 4).forget();

// 3. Spawn a task into the queue and synchronously await its completion. assert_eq!(queue.spawn(once(|| { println!("This will execute on background thread."); 2 })).join(), 2);

// ...or, asynchronously await its completion. assert_eq!(queue.spawn(once(|| { println!("This will execute on background thread."); 2 })).await, 2); ```