task-system 0.1.0

A system that manage cancelable task.
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 std::{
    collections::VecDeque,
    fmt::{Debug, Formatter},
    sync::{Arc, Mutex, MutexGuard, PoisonError},
};

mod sender;
mod system;

/// A task system that can be used to send tasks to a thread pool.
pub struct TaskSystem<T> {
    interrupt: Arc<Mutex<bool>>,
    queue: Arc<Mutex<VecDeque<T>>>,
}

/// Sender for a task system.
pub struct TaskSender<T> {
    refer: TaskSystem<T>,
}

fn send_task<T>(queue: &Arc<Mutex<VecDeque<T>>>, task: T) -> Result<(), PoisonError<MutexGuard<'_, VecDeque<T>>>> {
    match queue.lock() {
        Ok(mut o) => Ok(o.push_back(task)),
        Err(e) => Err(e),
    }
}