taskqueue 0.1.1

Parallel execution of the task queue with the ability to add new tasks inside the running tasks
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

use crate::{events::WorkerToControlEvent, worker::WorkerId, WorkerToControllerChanelSender};

pub struct TaskReceiver {
    channel: WorkerToControllerChanelSender,
}

impl TaskReceiver {
    pub(crate) fn new(channel: WorkerToControllerChanelSender) -> Self {
        Self { channel }
    }

    pub fn add_task(&self, task: Task) {
        self.channel.send(WorkerToControlEvent::AddTask(task)).ok();
    }
}

pub enum TaskControlCommand {
    Continue,
    Abort,
}

pub trait RunTask {
    fn run(self: Box<Self>, id: WorkerId, task_receiver: TaskReceiver) -> TaskControlCommand;
}

pub type Task = Box<dyn RunTask + Send>;