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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use fehler::throws;
use std::collections::HashMap;

use crate::{errors, ControllerToWorkerChanelSender, Error, Panic};

pub type WorkerId = usize;
pub type Workers = HashMap<WorkerId, Worker>;

pub struct Worker {
    thread: Option<std::thread::JoinHandle<()>>,
    pub channel: ControllerToWorkerChanelSender,
}

impl Drop for Worker {
    fn drop(&mut self) {
        if self.thread.is_some() {
            panic!("WorkerHandle::drop, 'join' not called on worker thread");
        }
    }
}

impl Worker {
    pub(crate) fn new(
        thread: std::thread::JoinHandle<()>,
        channel: ControllerToWorkerChanelSender,
    ) -> Self {
        Self {
            thread: Some(thread),
            channel,
        }
    }

    #[throws]
    pub fn join(&mut self) -> Panic {
        self.thread
            .take()
            .ok_or_else(|| errors::EmptyWorkerThreadHandle.build())?
            .join()
            .err()
    }
}