Crate threadlanes

Real-time executors with deterministic task routing and guaranteed ordering.

Example

use threadlanes::{ThreadLanes, LaneExecutor};

struct MyExecutor {
    id: usize,
}
impl LaneExecutor<usize> for MyExecutor {
    fn execute(&mut self, task: usize) {
       println!("{} received {}", self.id, task);
    }
}

fn main() {
    let lanes = ThreadLanes::new(vec![
        MyExecutor{id: 0},
        MyExecutor{id: 1},
        MyExecutor{id: 2},
    ]);
     
    lanes.send(0, 11); // send task=11 to thread lane 0
    lanes.send(1, 12); // send task=12 to thread lane 1
    lanes.send(1, 13); // send task=13 to thread lane 1
    lanes.send(2, 14); // send task=14 to thread lane 2
    lanes.send(2, 15); // send task=15 to thread lane 2
    lanes.send(2, 16); // send task=16 to thread lane 2
    
    lanes.flush();
}

Why threadlanes

ThreadLanes are useful when you need deterministic task ordering through stateful Executors. This is in contrast to a thread pool, where the thread that executes a task is not deterministic.

Structs

ThreadLanes

A ThreadLanes instance manages underlying executors, their threads, and their queues.

Traits

LaneExecutor

Trait for user to define an Executor to be used by ThreadLanes