Struct hirofa_utils::task_manager::TaskManager

pub struct TaskManager { /* private fields */ }

Implementations

impl TaskManager

pub fn new(thread_count: usize) -> Self

pub fn add_task<T: FnOnce() + Send + 'static>(&self, task: T)

pub fn add_task_async<R: Send + 'static, T: Future<Output = R> + Send + 'static>( &self, task: T ) -> impl Future<Output = Result<R, JoinError>>

start an async task

Example

use hirofa_utils::task_manager::TaskManager;
let tm = TaskManager::new(2);
let task = async {
    println!("foo");
};
tm.add_task_async(task);

pub fn run_task_blocking<R: Send + 'static, T: FnOnce() -> R + Send + 'static>( &self, task: T ) -> R