Struct ThreadPool 

pub struct ThreadPool { /* private fields */ }

Enhanced thread pool with work-stealing and advanced features

Implementations

impl ThreadPool

pub fn new() -> Result<Self>

Create a new thread pool with default configuration

pub fn with_config(config: ThreadPoolConfig) -> Result<Self>

Create a new thread pool with custom configuration

pub fn submit<F>(&self, task: F) -> Result<u64>

where F: FnOnce() + Send + 'static,

Submit a task to the pool

pub fn submit_with_priority<F>( &self, task: F, priority: Priority, estimated_cost: Option<u64>, ) -> Result<u64>

where F: FnOnce() + Send + 'static,

Submit a task with priority and cost estimate

pub fn statistics(&self) -> ThreadPoolStats

Get pool statistics

pub fn num_threads(&self) -> usize

Get number of worker threads

pub fn pending_tasks(&self) -> usize

Get number of pending tasks

pub fn wait(&self) -> Result<()>

Wait for all pending tasks to complete

pub fn shutdown(self) -> Result<()>

Shutdown the thread pool gracefully

Trait Implementations

impl Default for ThreadPool

fn default() -> Self

Returns the “default value” for a type.