Specify a name for every thread notify creates

src/fsevent.rs

@@ -432,7 +432,7 @@ impl FsEventWatcher {
         // channel to pass runloop around
         let (rl_tx, rl_rx) = unbounded();
 
-        let thread_handle = thread::spawn(move || {
+        let thread_handle = thread::Builder::new().name("notify-rs fsevents".to_string()).spawn(move || {
             let stream = stream.0;
 
             unsafe {

src/inotify.rs

@@ -128,7 +128,7 @@ impl EventLoop {
 
     // Run the event loop.
     pub fn run(self) {
-        thread::spawn(|| self.event_loop_thread());
+        thread::Builder::new().name("notify-rs inotify".to_string()).spawn(|| self.event_loop_thread());
     }
 
     fn event_loop_thread(mut self) {
@@ -418,7 +418,7 @@ impl EventLoop {
                             let event_loop_tx = self.event_loop_tx.clone();
                             let waker = self.event_loop_waker.clone();
                             let cookie = rename_event.tracker().unwrap(); // unwrap is safe because rename_event is always set with some cookie
-                            thread::spawn(move || {
+                            thread::Builder::new().name("notify-rs inotify rename".to_string()).spawn(move || {
                                 thread::sleep(Duration::from_millis(10)); // wait up to 10 ms for a subsequent event
 
                                 // An error here means the other end of the channel was closed, a thing that can

src/kqueue.rs

@@ -76,7 +76,7 @@ impl EventLoop {
 
     // Run the event loop.
     pub fn run(self) {
-        thread::spawn(|| self.event_loop_thread());
+        thread::Builder::new().name("notify-rs kqueue".to_string()).spawn(|| self.event_loop_thread());
     }
 
     fn event_loop_thread(mut self) {

src/poll.rs

@@ -76,7 +76,7 @@ impl PollWatcher {
         let event_handler = self.event_handler.clone();
         let event_handler = move |res| emit_event(&event_handler, res);
 
-        thread::spawn(move || {
+        thread::Builder::new().name("notify-rs poll".to_string()).spawn(move || {
             // In order of priority:
             // TODO: handle metadata events
             // TODO: handle renames

src/windows.rs

@@ -84,7 +84,7 @@ impl ReadDirectoryChangesServer {
         let (action_tx, action_rx) = unbounded();
         // it is, in fact, ok to send the semaphore across threads
         let sem_temp = wakeup_sem as u64;
-        thread::spawn(move || {
+        thread::Builder::new().name("notify-rs windows".to_string()).spawn(move || {
             let wakeup_sem = sem_temp as HANDLE;
             let server = ReadDirectoryChangesServer {
                 rx: action_rx,

tests/race-with-remove-dir.rs

@@ -10,7 +10,7 @@ fn test_race_with_remove_dir() {
 
     {
         let tmpdir = tmpdir.path().to_path_buf();
-        thread::spawn(move || {
+        thread::Builder::new().name("notify-rs test-race-with-remove-dir".to_string()).spawn(move || {
             let mut watcher = notify::recommended_watcher(move |result| {
                 eprintln!("received event: {:?}", result);
             })