perf(trie): parallelize HashedPostStateSorted::from_reverts

Parallelizes the hashing/sorting step using Rayon when account count
exceeds a threshold (2500). This alleviates CPU bottlenecks during large
state reverts or deep reorgs.

Closes #20049

Author: Andrurachi

Cargo.lock

@@ -50,10 +50,22 @@ proptest-arbitrary-interop.workspace = true
 serde_json.workspace = true
 similar-asserts.workspace = true
 
-criterion.workspace = true
-rand.workspace = true
-
 [features]
+default = ["std"]
+std = [
+    "dep:rayon",
+    "alloy-consensus/std",
+    "alloy-primitives/std",
+    "alloy-rlp/std",
+    "reth-chainspec/std",
+    "reth-execution-errors/std",
+    "reth-primitives-traits/std",
+    "revm/std",
+    "revm-database/std",
+    "serde_json/std",
+    "reth-trie-common/std",
+    "tracing/std",
+]
 metrics = ["reth-trie/metrics"]
 serde = [
     "similar-asserts/serde",
@@ -64,7 +76,6 @@ serde = [
     "reth-primitives-traits/serde",
     "revm-database/serde",
     "revm/serde",
-    "rand/serde",
 ]
 test-utils = [
     "reth-trie-common/test-utils",
@@ -75,14 +86,3 @@ test-utils = [
     "reth-provider/test-utils",
     "reth-trie/test-utils",
 ]
-
-parallel-from-reverts = ["dep:rayon"]
-
-[[bench]]
-name = "sorting_par_exp"
-harness = false
-required-features = ["parallel-from-reverts"]
-
-[[bench]]
-name = "integration_bench"
-harness = false

crates/trie/db/Cargo.toml

@@ -19,7 +19,7 @@ use std::{
 };
 use tracing::{debug, instrument};
 
-#[cfg(feature = "parallel-from-reverts")]
+#[cfg(feature = "std")]
 use rayon::iter::{IntoParallelIterator, ParallelIterator};
 
 /// Extends [`StateRoot`] with operations specific for working with a database transaction.
@@ -286,12 +286,14 @@ impl<TX: DbTx> DatabaseHashedPostState<TX> for HashedPostStateSorted {
         // Threshold based on benchmark
         const PARALLEL_THRESHOLD: usize = 2_500;
 
-        // Check Feature Flag AND Threshold
-        let use_parallel =
-            cfg!(feature = "parallel-from-reverts") && storages.len() >= PARALLEL_THRESHOLD;
+        #[cfg(feature = "std")]
+        let use_parallel = storages.len() >= PARALLEL_THRESHOLD;
+
+        #[cfg(not(feature = "std"))]
+        let use_parallel = false;
 
         let hashed_storages = if use_parallel {
-            #[cfg(feature = "parallel-from-reverts")]
+            #[cfg(feature = "std")]
             {
                 storages
                     .into_par_iter()
@@ -301,7 +303,7 @@ impl<TX: DbTx> DatabaseHashedPostState<TX> for HashedPostStateSorted {
                     })
                     .collect()
             }
-            #[cfg(not(feature = "parallel-from-reverts"))]
+            #[cfg(not(feature = "std"))]
             {
                 unreachable!()
             }