refactor: removing parking_lock

Author: Boshen

Cargo.lock

@@ -34,7 +34,6 @@ serde_json = "1"
 dyn-clone = "1"
 rustc-hash = "1"
 once_cell = "1"
-parking_lot = "0.12"
 dashmap = "5"
 substring = "1"
 smallvec = "1.11.2"

Cargo.toml

@@ -4,12 +4,11 @@ use std::{
   hash::{Hash, Hasher},
   sync::{
     atomic::{AtomicBool, Ordering},
-    Arc,
+    Arc, Mutex, MutexGuard,
   },
 };
 
 use once_cell::sync::OnceCell;
-use parking_lot::Mutex;
 use rustc_hash::FxHashMap as HashMap;
 
 use crate::{
@@ -103,13 +102,16 @@ impl<T> ReplaceSource<T> {
     &self.inner
   }
 
+  fn replacements(&self) -> MutexGuard<Vec<Replacement>> {
+    self.replacements.lock().unwrap()
+  }
+
   fn sort_replacement(&self) {
     if self.is_sorted.load(Ordering::SeqCst) {
       return;
     }
     self
-      .replacements
-      .lock()
+      .replacements()
       .sort_by(|a, b| (a.start, a.end).cmp(&(b.start, b.end)));
     self.is_sorted.store(true, Ordering::SeqCst)
   }
@@ -135,7 +137,7 @@ impl<T: Source> ReplaceSource<T> {
     content: &str,
     name: Option<&str>,
   ) {
-    self.replacements.lock().push(Replacement::new(
+    self.replacements().push(Replacement::new(
       start,
       end,
       content.into(),
@@ -155,7 +157,7 @@ impl<T: Source + Hash + PartialEq + Eq + 'static> Source for ReplaceSource<T> {
     // concatenate strings benchmark, see https://github.com/hoodie/concatenation_benchmarks-rs
     let mut source_code = String::new();
     let mut inner_pos = 0;
-    for replacement in self.replacements.lock().iter() {
+    for replacement in self.replacements.lock().unwrap().iter() {
       if inner_pos < replacement.start {
         let end_pos = (replacement.start as usize).min(inner_source_code.len());
         source_code.push_str(&inner_source_code[inner_pos as usize..end_pos]);
@@ -185,7 +187,7 @@ impl<T: Source + Hash + PartialEq + Eq + 'static> Source for ReplaceSource<T> {
   }
 
   fn map(&self, options: &crate::MapOptions) -> Option<SourceMap> {
-    let replacements = self.replacements.lock();
+    let replacements = self.replacements.lock().unwrap();
     if replacements.is_empty() {
       return self.inner.map(options);
     }
@@ -223,7 +225,7 @@ impl<T: std::fmt::Debug> std::fmt::Debug for ReplaceSource<T> {
 
 impl<T: Source> StreamChunks for ReplaceSource<T> {
   fn mappings_size_hint(&self) -> usize {
-    self.replacements.lock().len() * 2
+    self.replacements.lock().unwrap().len() * 2
   }
 
   fn stream_chunks(
@@ -235,7 +237,7 @@ impl<T: Source> StreamChunks for ReplaceSource<T> {
   ) -> crate::helpers::GeneratedInfo {
     self.sort_replacement();
     let on_name = RefCell::new(on_name);
-    let repls = self.replacements.lock();
+    let repls = self.replacements();
     let mut pos: u32 = 0;
     let mut i: usize = 0;
     let mut replacement_end: Option<u32> = None;
@@ -646,7 +648,7 @@ impl<T: Source> Clone for ReplaceSource<T> {
     Self {
       inner: self.inner.clone(),
       inner_source_code: self.inner_source_code.clone(),
-      replacements: Mutex::new(self.replacements.lock().clone()),
+      replacements: Mutex::new(self.replacements().clone()),
       is_sorted: AtomicBool::new(true),
     }
   }
@@ -656,7 +658,7 @@ impl<T: Hash> Hash for ReplaceSource<T> {
   fn hash<H: Hasher>(&self, state: &mut H) {
     self.sort_replacement();
     "ReplaceSource".hash(state);
-    for repl in self.replacements.lock().iter() {
+    for repl in self.replacements().iter() {
       repl.hash(state);
     }
     self.inner.hash(state);
@@ -665,8 +667,7 @@ impl<T: Hash> Hash for ReplaceSource<T> {
 
 impl<T: PartialEq> PartialEq for ReplaceSource<T> {
   fn eq(&self, other: &Self) -> bool {
-    self.inner == other.inner
-      && *self.replacements.lock() == *other.replacements.lock()
+    self.inner == other.inner && *self.replacements() == *other.replacements()
   }
 }