driveshaft 0.1.1

A minimal, high-performance thread pool for running synchronous tasks with per-thread context from async code.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

mod error;
mod job;
mod pool;
mod worker;

pub use crate::{
    error::DriveShaftError, pool::DriveShaftPool, pool::DriveShaftPoolBuilder, worker::WorkerType,
};

#[cfg(test)]
mod tests {

    use crate::{pool::DriveShaftPoolBuilder, worker::WorkerType};

    #[tokio::test]
    async fn test_create_worker() {
        let job = |ctx: &mut u8| {
            println!("Executed Job {}", ctx);
            ctx.clone()
        };

        let mut drive_shaft_pool = DriveShaftPoolBuilder::new()
            .worker_type(WorkerType::UnBound)
            .build(vec![1]);

        let _ = drive_shaft_pool.run_with(job).await;
    }
}