Crate jtp

Thread Pool

A thread pool allows you to execute asyncronous tasks without creating new threads for each one. It improves the performance and the resource utilization by limiting the number of threads.

Build a thread pool

You can use the ThreadPoolBuilder to build a thread pool with the custom configuration.

Examples

use jtp::ThreadPoolBuilder;
let mut thread_pool = ThreadPoolBuilder::default()
    .core_pool_size(5)
    .max_pool_size(10)
    .channel_capacity(100)
    .build()
    .unwrap();

thread_pool.execute(|| println!("Hello World")).unwrap();

// Close the thread pool and wait for all worker threads to end.
thread_pool.wait();

Structs

• TPBuilderError
  An error returned from the ThreadPoolBuilder::build.
• ThreadPool
  A ThreadPool consists of a collection of reusable threads and a bounded channel that is used to transfer and hold submitted tasks.
• ThreadPoolBuilder
  A builder of the ThreadPool, which can be used to configure the properties of a new thread pool.

Enums

• RejectedTaskHandler
  If a task is rejected, the task will be handled by this.
• TPError
  An error returned from the ThreadPool::execute.

Type Definitions

• ThreadFactory
  A function that used to create a custom thread.