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

use snafu::Snafu;

#[derive(Debug, Snafu)]
#[snafu(visibility(pub))]
pub enum Error {
    #[snafu(display("Empty worker thread handle"))]
    EmptyWorkerThreadHandle,

    #[snafu(display("Empty controller thread handle"))]
    EmptyControllerThreadHandle,

    #[snafu(display("Worker not found, id: {}", id))]
    WorkerNotFound { id: usize },

    #[snafu(display("Sync poison error: {}", description))]
    PoisonError { description: String },

    #[snafu(display("Task queue send task error. {}", explanation))]
    TaskQueueSendError { explanation: String },
}

pub type Result<T, E = Error> = std::result::Result<T, E>;