diff options
-rw-r--r-- | Cargo.lock | 4 | ||||
-rw-r--r-- | Cargo.toml | 2 | ||||
-rw-r--r-- | src/common.rs | 11 |
3 files changed, 13 insertions, 4 deletions
@@ -380,9 +380,9 @@ dependencies = [ [[package]] name = "jwalk" -version = "0.8.0" +version = "0.8.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "37cb840f933b9fa56c78fde73acc9f2c883a2594fc6c791992a133468106965d" +checksum = "2735847566356cd2179a2a38264839308f7079fa96e6bd5a42d740460e003c56" dependencies = [ "crossbeam", "rayon", @@ -19,7 +19,7 @@ trash-move = ["trash"] [dependencies] clap = { version = "4.0.29", features = ["derive"] } -jwalk = "0.8.0" +jwalk = "0.8.1" byte-unit = "4" atty = "0.2.11" petgraph = "0.6" diff --git a/src/common.rs b/src/common.rs index 45e9738..f5f862e 100644 --- a/src/common.rs +++ b/src/common.rs @@ -160,7 +160,16 @@ impl WalkOptions { busy_timeout: std::time::Duration::from_secs(1), }, 1 => jwalk::Parallelism::Serial, - _ => jwalk::Parallelism::RayonNewPool(self.threads), + _ => jwalk::Parallelism::RayonExistingPool { + pool: jwalk::rayon::ThreadPoolBuilder::new() + .stack_size(128 * 1024) + .num_threads(self.threads) + .thread_name(|idx| format!("dua-fs-walk-{idx}")) + .build() + .expect("fields we set cannot fail") + .into(), + busy_timeout: None, + }, }) } } |