Merge pull request #38 from utkarshgupta137/main

Add a name to unpacking thread
jonhoo · Aug 20, 2023 · 469c547 · 469c547
2 parents 48769f2 + 71dbbc6
commit 469c547
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,