Struct WorkerThread 

pub struct WorkerThread<'scope, V, T>
where
    V: Send,
{
    pub thread: Option<ScopedJoinHandle<'scope, Vec<T>>>,
    pub name: String,
    /* private fields */
}

Worker thread is launched by the thread manager based on the need discovered by the scheduling algorithm within worker controller.

Fields

thread: Option<ScopedJoinHandle<'scope, Vec<T>>>

name: String

Implementations

impl<'scope, V, T> WorkerThread<'scope, V, T>

where T: Send + Sync + 'scope, V: Send + Sync + 'scope,

pub fn launch<'env, 'a, F>( scope: &'scope Scope<'scope, 'env>, pos: usize, f: Arc<RwLock<F>>, ) -> Result<Self, Box<dyn Error>>

where V: Send + Sync + 'scope, F: Fn(V) -> T + Send + Sync + 'scope, 'env: 'scope,

pub fn name(&self) -> &String

pub fn signal(&mut self, state: Coordination)

pub fn is_running(&mut self) -> bool

pub fn run(&mut self, values: Vec<V>) -> Result<(), WorkThreadError>

Run function runs a new batch of tasks on the thread

pub fn pos(&self) -> usize

pub fn unpark(&self)

pub fn join(self) -> Result<Vec<T>, Box<dyn Any + Send + 'static>>

where V: Send + Sync + 'scope,

pub fn queue_len(&self) -> usize

pub fn steal(&mut self) -> Option<Vec<V>>

pub fn steal_half(&mut self) -> Option<Vec<V>>

pub fn is_queue_empty(&self) -> bool

pub fn queue_start_len(&self) -> usize

pub fn get_elapsed_time(&mut self) -> Option<u128>

pub fn time_per_process(&self) -> Option<f64>

pub fn predicted_queue_time(&self) -> f64

pub fn ratio_of_tasks_remaining(&self) -> Option<f64>

pub fn projected_time_for_completion( &self, min_ratio_completed: f64, ) -> Option<f64>