Struct tasque::TaskQueue

pub struct TaskQueue { /* fields omitted */ }

Task queue.

This queue spawns worker threads for executing registered tasks.

Examples

use tasque::TaskQueue;

let queue = TaskQueue::new();
queue.enqueue(|| println!("Hello"));
queue.enqueue(|| println!("World"));

Methods

impl TaskQueue

fn new() -> Self

Makes a new TaskQueue instance.

This is equivalent to TaskQueueBuilder::new().finish().

fn enqueue<F>(&self, task: F) where
    F: FnOnce() + Send + 'static, 

Enqueues a task.

The task will be executed by a worker thread.

If the thread panics while executing the task, it will be automatically restarted. Note that the task will not be retried in such case.

Trait Implementations

impl Debug for TaskQueue

fn fmt(&self, __arg_0: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Clone for TaskQueue

fn clone(&self) -> TaskQueue

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TaskQueue

fn default() -> Self

Returns the "default value" for a type.