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
27
28
29
30
31
32
33
34
35

use super::*;

impl<T> Clone for TaskSender<T> {
    fn clone(&self) -> Self {
        TaskSender { refer: TaskSystem { interrupt: self.refer.interrupt.clone(), queue: self.refer.queue.clone() } }
    }
}

impl<T> From<TaskSystem<T>> for TaskSender<T> {
    fn from(refer: TaskSystem<T>) -> Self {
        TaskSender { refer }
    }
}

impl<T> TaskSender<T> {
    /// Send a task to the task system.
    ///
    /// # Arguments
    ///
    /// * `task`:
    ///
    /// returns: Result<(), PoisonError<MutexGuard<VecDeque<T, Global>>>>
    ///
    /// # Examples
    ///
    /// ```
    /// use task_system::TaskSystem;
    /// let ts = TaskSystem::default();
    /// let ss = ts.sender();
    /// assert!(ss.send(1))
    /// ```
    pub fn send(&self, task: T) -> bool {
        send_task(&self.refer.queue, task).is_ok()
    }
}