recoverable_thread_pool/thread_pool/
type.rs

1use crate::worker::r#type::Worker;
2use recoverable_spawn::*;
3use std::sync::mpsc::{SendError, Sender};
4
5pub type ThreadPoolJob = Box<dyn RecoverableFunction>;
6pub type SendErrorBox = SendError<ThreadPoolJob>;
7pub type SendResult = Result<(), SendErrorBox>;
8
9pub struct ThreadPool {
10    #[allow(dead_code)]
11    pub(super) workers: Vec<Worker>,
12    pub(super) sender: Sender<ThreadPoolJob>,
13}