Add a name to unpacking thread

jonhoo · Jul 31, 2023 · 71dbbc6 · 71dbbc6
1 parent 48769f2
commit 71dbbc6
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -344,11 +344,13 @@ impl<T> Bus<T> {
         // so we don't have to wait for unpark() to return in broadcast_inner
         // sending on a channel without contention is cheap, unparking is not
         let (unpark_tx, unpark_rx) = mpsc::unbounded::<thread::Thread>();
-        thread::spawn(move || {
-            for t in unpark_rx.iter() {
-                t.unpark();
-            }
-        });
+        let _ = thread::Builder::new()
+            .name("bus_unparking".to_owned())
+            .spawn(move || {
+                for t in unpark_rx.iter() {
+                    t.unpark();
+                }
+            });
 
         Bus {
             state: inner,