when2task 0.3.1

high-performance library for executing async tasks with automatic dependency resolution and optimal parallelization.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use crate::blueprint::Blueprint;
use crate::{BuildError, ExecutionMode, Task, TaskExecutor, TaskId};
use dashmap::DashMap;

pub struct TaskExecutorBuilder<T, E> {
    tasks: DashMap<TaskId, Task<'static, T, E>>,
    mode: ExecutionMode<T, E>,
}

impl<T, E> TaskExecutorBuilder<T, E> {
    pub fn new(execution_mode: ExecutionMode<T, E>) -> Self {
        Self {
            tasks: Default::default(),
            mode: execution_mode,
        }
    }
    pub fn insert(&self, task: Task<'static, T, E>) -> &Self {
        self.tasks.insert(*task.id(), task);
        self
    }

    pub fn build(self) -> Result<TaskExecutor<T, E>, BuildError> {
        let blueprint = Blueprint::from_tasks(&self.tasks)?;

        Ok(TaskExecutor {
            mode: self.mode,
            tasks: self.tasks,
            blueprint,
        })
    }
}