zero-pool 0.8.3

High-performance thread pool with consistent low-latency task dispatch
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
29
30
31
32
33
34
35

use std::{
    sync::Arc,
    thread::{self, JoinHandle},
};

use crate::{queue::Queue, retired_list::RetiredList};

pub fn spawn_worker(id: usize, queue: Arc<Queue>) -> JoinHandle<()> {
    thread::Builder::new()
        .name(format!("zp{id}"))
        .spawn(move || {
            let mut retired = RetiredList::new();

            loop {
                if !queue.wait_for_work(id) {
                    break;
                }

                while let Some((batch, first_param)) = queue.get_next_batch(id, &mut retired) {
                    let mut completed = 1;
                    (batch.fn_ptr)(first_param);

                    while let Some(param) = batch.claim_next_param() {
                        (batch.fn_ptr)(param);
                        completed += 1;
                    }

                    batch.future.complete_many(completed);

                    retired.try_clean(&queue);
                }
            }
        })
        .expect("spawn failed")
}