Log job queue overflows

ss220-space · May 8, 2021 · e631443 · e631443
1 parent 85f2965
commit e631443
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/jobs.rs b/src/jobs.rs
@@ -24,7 +24,11 @@ struct Jobs {
 impl Jobs {
     fn start<F: FnOnce() -> Output + Send + 'static>(&mut self, f: F) -> JobId {
         let (tx, rx) = mpsc::channel();
-        self.pool.execute_to(tx, Thunk::of(|| f()));
+        if self.pool.queued_count() > self.pool.max_count() {
+            log::warn!("Job queue filling up (active {}, queued {})", self.pool.active_count(), self.pool.queued_count());
+        }
+
+        self.pool.execute_to(tx, Thunk::of(f));
         let id = self.next_job.to_string();
         self.next_job += 1;
         self.map.insert(id.clone(), Job { rx });