Struct Queue 

pub struct Queue { /* private fields */ }

The MVSync queue. A single queue exists per MVSync instance. It is ran on its own thread, and distributes tasks efficiently between threads that are allocated to MVSync.

If a task that is submitted is waiting on a semaphore, it will not be submitted until it is ready, to prevent the workers from being clogged by functions that are waiting for other functions.

Implementations

impl Queue

pub fn submit(&self, task: Task)

Submit a task to the queue. This will push the task to the back of the queue. When there is a free worker available, the task will be popped off the queue and executed by the worker.

Arguments

task - The task to push to the back of the queue.

pub fn submit_all(&self, tasks: Vec<Task>)

Submit a vec of tasks to the queue. This will push the task to the back of the queue. When there is a free worker available, the task will be popped off the queue and executed by the worker in order.

Arguments

tasks - The vec of tasks to push to the back of the queue.

pub fn submit_on(&self, task: Task, thread: &str)

Submit a task to the queue. This will push the task to the back of the queue. When there is a free worker available on the given thread, the task will be popped off the queue and executed by the worker.

Arguments

task - The task to push to the back of the queue.

pub fn submit_all_on(&self, tasks: Vec<Task>, thread: &str)

Submit a vec of tasks to the queue. This will push the task to the back of the queue. When there is a free worker available on the given thread, the task will be popped off the queue and executed by the worker in order.

Arguments

tasks - The vec of tasks to push to the back of the queue.

Trait Implementations

impl PartialEq for Queue

fn eq(&self, other: &Queue) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Queue