diff --git a/pageserver/src/tenant_jobs/worker.rs b/pageserver/src/tenant_jobs/worker.rs index d8ad72b377..d093137c26 100644 --- a/pageserver/src/tenant_jobs/worker.rs +++ b/pageserver/src/tenant_jobs/worker.rs @@ -130,6 +130,15 @@ where condvar: Arc, // Notified when idle worker should wake up } +impl Default for Pool +where + J::ErrorType: Debug, +{ + fn default() -> Self { + Self::new() + } +} + impl Pool where J::ErrorType: Debug, diff --git a/pageserver/src/thread_mgr.rs b/pageserver/src/thread_mgr.rs index a30eae2be4..1d0ea01a52 100644 --- a/pageserver/src/thread_mgr.rs +++ b/pageserver/src/thread_mgr.rs @@ -60,7 +60,7 @@ lazy_static! { /// Global registry of threads static ref THREADS: Mutex>> = 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>> = Mutex::new(Vec::new()); }