Struct ThreadPoolExecutor

pub struct ThreadPoolExecutor { /* private fields */ }

A ThreadPoolExecutor will use one thread for the task scheduling and a thread pool for task execution, allowing multiple tasks to run in parallel.

Implementations

impl ThreadPoolExecutor

pub fn new(threads: usize) -> Result<ThreadPoolExecutor, Error>

Creates a new ThreadPoolExecutor with the specified number of threads. Threads will be named “pool_thread_0”, “pool_thread_1” and so on.

pub fn with_prefix( threads: usize, prefix: &str, ) -> Result<ThreadPoolExecutor, Error>

Creates a new ThreadPoolExecutor with the specified number of threads and prefix for the thread names.

pub fn with_executor( threads: usize, prefix: &str, executor: CoreExecutor, ) -> ThreadPoolExecutor

Creates a new ThreadPoolExecutor with the specified number of threads, prefix and using the given CoreExecutor for scheduling.

pub fn schedule_fixed_rate<F>( &self, initial: Duration, interval: Duration, scheduled_fn: F, ) -> TaskHandle

where F: Fn(&Remote) + Send + Sync + 'static,

Schedules the given function to be executed every interval. The function will be scheduled on one of the threads in the thread pool.

pub fn pool(&self) -> &CpuPool

Returns the thread pool used internally.

Trait Implementations

impl Clone for ThreadPoolExecutor

fn clone(&self) -> ThreadPoolExecutor

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl TaskGroupScheduler for ThreadPoolExecutor

fn schedule<T: TaskGroup>( &self, task_group: T, initial: Duration, interval: Duration, ) -> Arc<T>