perf: parking_lot

Author: transmissions11

Cargo.lock

@@ -28,4 +28,5 @@ simple-tqdm = { version = "0.2.0", features = ["rayon"] }
 rand = "0.9.1"
 ratelimit = "0.10"
 clap = { version = "4.5", features = ["derive", "env"] }
-toml = "0.8"
+toml = "0.8"
+parking_lot = "0.12.4"

crescendo/Cargo.toml

@@ -1,8 +1,8 @@
 use std::collections::VecDeque;
 use std::sync::atomic::{AtomicU64, Ordering};
-use std::sync::Mutex;
 use std::time::Duration;
 
+use parking_lot::Mutex;
 use ratelimit::Ratelimiter;
 use thousands::Separable;
 
@@ -39,15 +39,15 @@ pub static TX_QUEUE: std::sync::LazyLock<TxQueue> = std::sync::LazyLock::new(TxQ
 impl TxQueue {
     pub fn push_tx(&self, tx: Vec<u8>) {
         self.total_added.fetch_add(1, Ordering::Relaxed);
-        self.queue.lock().unwrap().push_back(tx);
+        self.queue.lock().push_back(tx);
     }
 
     pub fn queue_len(&self) -> usize {
-        self.queue.lock().map(|q| q.len()).unwrap_or(0)
+        self.queue.lock().len()
     }
 
     pub async fn pop_at_most(&self, max_count: usize) -> Option<Vec<Vec<u8>>> {
-        let mut queue = self.queue.lock().ok()?;
+        let mut queue = self.queue.lock();
         let allowed = (0..queue.len().min(max_count)).take_while(|_| self.rate_limiter.try_wait().is_ok()).count();
         if allowed == 0 {
             return None;

crescendo/src/tx_queue.rs

@@ -1,5 +1,5 @@
 use std::collections::HashMap;
-use std::sync::{LazyLock, Mutex};
+use std::sync::LazyLock;
 use std::time::Instant;
 
 use alloy::network::TxSignerSync;
@@ -9,6 +9,7 @@ use alloy::sol_types::SolCall;
 use alloy_consensus::{SignableTransaction, TxLegacy};
 use alloy_signer_local::coins_bip39::English;
 use alloy_signer_local::{MnemonicBuilder, PrivateKeySigner};
+use parking_lot::Mutex;
 use rand::Rng;
 use rayon::prelude::*;
 use thousands::Separable;
@@ -52,7 +53,7 @@ pub fn tx_gen_worker(_worker_id: u32) {
 
         // Get and increment nonce atomically.
         let nonce = {
-            let mut nonce_map = NONCE_MAP.lock().unwrap();
+            let mut nonce_map = NONCE_MAP.lock();
             let current_nonce = *nonce_map.get(&account_index).unwrap();
             nonce_map.insert(account_index, current_nonce + 1);
             current_nonce