recoverable_thread_pool/worker/
impl.rs

1use super::r#type::Worker;
2use crate::thread_pool::r#type::ThreadPoolJob;
3use recoverable_spawn::*;
4use std::sync::{mpsc::Receiver, Arc, Mutex};
5
6impl Worker {
7    #[inline]
8    pub fn new(id: usize, receiver: Arc<Mutex<Receiver<ThreadPoolJob>>>) -> Option<Worker> {
9        sync::recoverable_spawn(move || loop {
10            if let Ok(receiver_lock) = receiver.lock() {
11                if let Ok(job) = receiver_lock.recv() {
12                    let _ = sync::recoverable_spawn(job);
13                }
14            }
15        });
16        return Some(Worker { id });
17    }
18}