Struct TaskSystem

pub struct TaskSystem<T> { /* private fields */ }

A task system that can be used to send tasks to a thread pool.

Implementations

impl<T> TaskSystem<T>

pub fn cancel_if<F>(&self, condition: F) -> Vec<T>

where F: Fn(&T) -> bool + Send + 'static, T: Send + 'static,

Cancel all tasks that match the condition.

Arguments

• condition:

returns: Vec<T, Global>

Examples

use task_system::TaskSystem;
let ts = TaskSystem::default();
(1..10).for_each(|i| {
    ts.send(i);
});
assert_eq!(ts.cancel_if(|i| i % 2 == 0), vec![2, 4, 6, 8]);

pub fn cancel_first<F>(&self, condition: F) -> Option<T>

where F: Fn(&T) -> bool + Send + 'static, T: Send + 'static,

Cancel the first task that matches the condition.

Arguments

• condition:

returns: Option

Examples

use task_system::TaskSystem;
let ts = TaskSystem::default();
(1..10).for_each(|i| {
    ts.send(i);
});
assert_eq!(ts.cancel_first(|i| *i == 5), Some(5));

pub fn send(&self, task: T) -> bool

Send a new task to the task system.

pub fn sender(&self) -> TaskSender<T>

Get a sender for the task system.

pub fn receive(&self) -> Option<T>

Receive a task from the task system.

pub fn consume<F>(&self, callback: F) -> bool

where F: Fn(T) -> bool + Send + 'static, T: Send + 'static,

Consume a task from the task system.

pub fn interrupt(&self)

Interrupt all task runner.

pub fn resume(&self)

Stop interrupting task runner.

Trait Implementations

impl<T: Debug> Debug for TaskSystem<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Default for TaskSystem<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T: Debug> Display for TaskSystem<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> From<TaskSystem<T>> for TaskSender<T>

fn from(refer: TaskSystem<T>) -> Self

Converts to this type from the input type.