Crate ordq

Order keeping job processing queue.

This module provides a multithreaded worker pool that processes tasks while keeping the order of outputs.

Example:

struct Add;

impl ordq::Work for Add {
    type I = (i32, i32);
    type O = i32;

    fn run(&mut self, x: Self::I) -> Self::O {
        x.0 + x.1
    }
}

let (tx, rx) = ordq::new(1024, vec![Add, Add]);

tx.send((1, 2));
tx.send((3, 4));
tx.send((5, 6));

tx.close();

assert_eq!(rx.recv(), Some(Ok(3)));
assert_eq!(rx.recv(), Some(Ok(7)));
assert_eq!(rx.recv(), Some(Ok(11)));
assert_eq!(rx.recv(), None);
assert_eq!(rx.recv(), None);

Structs

Receiver

Receives job output from the thread pool.

RecvError

Error when a worker failed to send the output.

SendError

Error when a sender failed to send the input because of receiving end is dropped

Sender

The input sender that sends job input to the workers.

Stats

Worker stats

Traits

Work

Work can do some work with input I, and output O.

Functions

new

Create a worker thread pool with the given queue capacity and workers.