Struct BatchExecutor 

pub struct BatchExecutor<T> { /* private fields */ }

A batch executor for running multiple tasks and collecting their results

Implementations

impl<T: Send + 'static> BatchExecutor<T>

pub fn new(thread_pool: Arc<ThreadPool>) -> Self

Create a new batch executor with the given thread pool

pub fn add_task<F>(&mut self, future: F, priority: usize)

where F: Future<Output = ThreadPoolResult<T>> + Send + 'static,

Add a task to the batch

pub fn add_task_fn<F>(&mut self, f: F, priority: usize)

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

Add a task from a closure to the batch

pub async fn execute(self) -> Vec<ThreadPoolResult<T>>

Execute all tasks and collect their results

pub fn execute_stream(self) -> impl Stream<Item = ThreadPoolResult<T>>

Execute all tasks and return a stream of results as they complete