fixup: use RwLock

Author: link2xt

src/debouncer.rs

@@ -13,12 +13,12 @@
 
 use std::cmp::Reverse;
 use std::collections::{BinaryHeap, HashSet};
-use std::sync::Mutex;
+use std::sync::RwLock;
 use std::time::{Duration, Instant};
 
 #[derive(Default)]
 pub(crate) struct Debouncer {
-    state: Mutex<DebouncerState>,
+    state: RwLock<DebouncerState>,
 }
 
 #[derive(Default)]
@@ -76,12 +76,12 @@ impl Debouncer {
     /// Returns true if the token was notified recently
     /// and should not be notified again.
     pub(crate) fn is_debounced(&self, now: Instant, token: &String) -> bool {
-        let mut state = self.state.lock().unwrap();
+        let mut state = self.state.write().unwrap();
         state.is_debounced(now, token)
     }
 
     pub(crate) fn notify(&self, now: Instant, token: String) {
-        self.state.lock().unwrap().notify(now, token);
+        self.state.write().unwrap().notify(now, token);
     }
 
     /// Returns number of currently debounced notification tokens.
@@ -90,7 +90,7 @@ impl Debouncer {
     ///
     /// This function does not remove expired tokens.
     pub(crate) fn count(&self) -> usize {
-        self.state.lock().unwrap().count()
+        self.state.read().unwrap().count()
     }
 }