Struct command_executor::thread_pool_builder::ThreadPoolBuilder

pub struct ThreadPoolBuilder { /* private fields */ }

Build a ThreadPool

Modify default thread pool parameters and build the thread pool

Implementations

impl ThreadPoolBuilder

pub fn new() -> ThreadPoolBuilder

Create a new builder

Default values:

• name - “unnamed”
• tasks - 1
• queue_size - 16
• join_error_handler - a simple panicking error handler
• shutdown_mode - ShutdownMode::Immediate

Example

use command_executor::shutdown_mode::ShutdownMode;
use command_executor::thread_pool::ThreadPool;
use command_executor::thread_pool_builder::ThreadPoolBuilder;

fn create_thread_pool() -> Result<ThreadPool, anyhow::Error> {
    ThreadPoolBuilder::new()
        .name_str("example")
        .tasks(4)
        .queue_size(16)
        .shutdown_mode(ShutdownMode::CompletePending)
        .build()
}

pub fn name(&mut self, name: String) -> &mut ThreadPoolBuilder

Set the base name for threads in the thread pool

pub fn name_str(&mut self, name: &str) -> &mut ThreadPoolBuilder

Set the base name for threads in the thread pool. A convenience method that accepts &str

pub fn tasks(&mut self, tasks: usize) -> &mut ThreadPoolBuilder

Set the number of threads in the thread pool

pub fn shutdown_mode( &mut self, shutdown_mode: ShutdownMode ) -> &mut ThreadPoolBuilder

Specify the ShutdownMode

pub fn queue_size(&mut self, queue_size: usize) -> &mut ThreadPoolBuilder

Specify the queue size for the thread pool

pub fn join_error_handler( &mut self, join_error_handler: fn(_: String, _: String) ) -> &mut ThreadPoolBuilder

Set the error handler that is called for each thread that exited with error during join

pub fn build(&self) -> Result<ThreadPool, Error>

Build the thread pool