Struct thread_manager::ThreadManagerRaw

pub struct ThreadManagerRaw<F, T>
where
    F: Fn() -> T + Send + 'static,
    T: Send + 'static,
{ /* private fields */ }

A thread manager for executing jobs in parallel. This struct manages a pool of worker threads and distributes jobs among them.

Type Parameters

• F: The type of the function or closure that the threads will execute.
• T: The type of the value returned by the function or closure.

Fields

• wpc: The number of Workers-Per-Channel.
• dispatch: An instance of DispatchCycle to manage job distribution.
• workers: A vector of ThreadWorker instances representing the worker threads.
• channels: A vector of job channels for dispatching jobs to workers.
• result_channel: A channel for collecting the results of the jobs.
• manager_status: An instance of ManagerStatus to track the status of the manager.

Implementations

impl<F, T> ThreadManagerRaw<F, T>

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

pub fn new(size: usize) -> Self

Creates a new instance of ThreadManagerRaw with a specified number of worker threads.

Arguments

• size: The number of worker threads to create.

Returns

A new instance of ThreadManagerRaw.

pub fn new_asymmetric(size: usize, wpc: usize) -> Self

Creates a new instance of ThreadManagerRaw with a specified number of worker threads and a specific workers-per-channel ratio.

Arguments

• size: The number of worker threads to create.
• wpc: The number of workers per channel.

Returns

A new instance of ThreadManagerRaw with the specified configuration.

pub fn execute(&self, function: F)

Executes a given function by sending it to an available worker thread.

Arguments

• function: The function to be executed by the worker thread.

pub fn resize(&mut self, size: usize)

Resizes the pool of worker threads.

Arguments

• size: The new size of the worker pool.

impl<F, T> ThreadManagerRaw<F, T>

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

pub fn join(&self)

pub fn terminate_all(&self)

pub fn job_distribution(&self) -> Vec<usize>

pub fn has_finished(&self) -> bool

pub fn results<'a>(&'a self) -> ResultIter<'a, T>

pub fn yield_results<'a>(&'a self) -> YieldResultIter<'a, F, T>

pub fn active_threads(&self) -> usize

pub fn busy_threads(&self) -> usize

pub fn waiting_threads(&self) -> usize

pub fn job_queue(&self) -> usize

pub fn sent_jobs(&self) -> usize

pub fn received_jobs(&self) -> usize

pub fn concluded_jobs(&self) -> usize

Trait Implementations

impl<F, T> Drop for ThreadManagerRaw<F, T>

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

fn drop(&mut self)

Executes the destructor for this type.