This commit is contained in:
Bojan Serafimov
2022-05-25 11:31:22 -04:00
parent a8f0124af7
commit 8c78a5e9a6
2 changed files with 10 additions and 1 deletions

View File

@@ -130,6 +130,15 @@ where
condvar: Arc<Condvar>, // Notified when idle worker should wake up
}
impl<J: Job> Default for Pool<J>
where
J::ErrorType: Debug,
{
fn default() -> Self {
Self::new()
}
}
impl<J: Job> Pool<J>
where
J::ErrorType: Debug,

View File

@@ -60,7 +60,7 @@ lazy_static! {
/// Global registry of threads
static ref THREADS: Mutex<HashMap<u64, Arc<PageServerThread>>> = Mutex::new(HashMap::new());
// TODO make these per thread?
// TODO make these per thread for targetted shutdown, also for cleanup.
/// Condvars to notify after shutdown request
static ref SHUTDOWN_CONDVARS: Mutex<Vec<Arc<Condvar>>> = Mutex::new(Vec::new());
}