Channel length 0 is enough to notify drop

akiradeveloper · Nov 5, 2024 · c6be3c5 · c6be3c5
1 parent b290787
commit c6be3c5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sorock/src/backend/redb/mod.rs b/sorock/src/backend/redb/mod.rs
@@ -20,7 +20,7 @@ impl Backend {
         let db = Arc::new(redb);
 
         let (reaper, tx) = log::Reaper::new(db.clone());
-        let (_kill_tx, kill_rx) = crossbeam::channel::bounded(1);
+        let (_kill_tx, kill_rx) = crossbeam::channel::bounded(0);
         std::thread::spawn(move || loop {
             if let Err(TryRecvError::Disconnected) = kill_rx.try_recv() {
                 break;