Struct TaskQueue

pub struct TaskQueue { /* private fields */ }

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"));

Implementations

impl TaskQueue

pub fn new() -> Self

Makes a new TaskQueue instance.

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

Examples found in repository

examples/metrics.rs (line 9)

fn main() {
    let queue = TaskQueue::new();
    queue.enqueue(|| thread::sleep(Duration::from_millis(1)));
    queue.enqueue(|| thread::sleep(Duration::from_millis(50)));
    queue.enqueue(|| thread::sleep(Duration::from_millis(1000)));
    thread::sleep(Duration::from_millis(100));

    println!(
        "{}",
        prometrics::default_gatherer()
            .lock()
            .unwrap()
            .gather()
            .to_text()
    );
}

pub 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.

Examples found in repository

examples/metrics.rs (line 10)

fn main() {
    let queue = TaskQueue::new();
    queue.enqueue(|| thread::sleep(Duration::from_millis(1)));
    queue.enqueue(|| thread::sleep(Duration::from_millis(50)));
    queue.enqueue(|| thread::sleep(Duration::from_millis(1000)));
    thread::sleep(Duration::from_millis(100));

    println!(
        "{}",
        prometrics::default_gatherer()
            .lock()
            .unwrap()
            .gather()
            .to_text()
    );
}

pub fn set_worker_count(&self, count: usize)

Updates the number of worker threads of this queue.

pub fn worker_count(&self) -> usize

Returns the number of worker threads of this queue.

pub fn len(&self) -> usize

Returns the number of tasks (enqueued but not yet dequeued) in this queue.

Trait Implementations

impl Clone for TaskQueue

fn clone(&self) -> TaskQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskQueue

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

Formats the value using the given formatter.

impl Default for TaskQueue

fn default() -> Self

Returns the “default value” for a type.