Struct WorkStealingThreadPool 

pub struct WorkStealingThreadPool { /* private fields */ }

Work-stealing thread pool for efficient parallel task distribution

This thread pool uses work-stealing to balance load across threads. Each thread maintains a local work queue, and idle threads can steal work from busy threads to maintain high utilization.

Implementations

impl WorkStealingThreadPool

pub fn new(n_threads: usize) -> Self

Create a new work-stealing thread pool

pub fn execute<F>(&self, task: F)

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

Submit a task to the thread pool

pub fn execute_parallel<F, T>(&self, tasks: Vec<F>) -> Vec<T>

where F: FnOnce() -> T + Send + 'static, T: Send + 'static,

Execute multiple tasks in parallel and wait for completion

pub fn n_threads(&self) -> usize

Get number of threads

Trait Implementations

impl Debug for WorkStealingThreadPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for WorkStealingThreadPool

fn drop(&mut self)

Executes the destructor for this type.