diff options
| author | jakka <jakka@jakka.su> | 2025-07-17 12:34:41 +0300 |
|---|---|---|
| committer | jakka <jakka@jakka.su> | 2025-07-17 12:34:41 +0300 |
| commit | 04eceb7e3d748c23517485d89035848cfe58a334 (patch) | |
| tree | e790351d65ee73c39e974d9107d6bea6553cd499 /src/main.rs | |
| parent | 566783c647fc85f1cfbe214e932aeb664e1f440d (diff) | |
test threading version without rayon
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/src/main.rs b/src/main.rs index 122ce60..d1e4562 100644 --- a/src/main.rs +++ b/src/main.rs @@ -116,11 +116,7 @@ fn main() -> Result<()> { if args.get_flag("doit") { let hanlder = running.clone(); let threads = *args.get_one::<usize>("threads").unwrap(); - let pool = rayon::ThreadPoolBuilder::new() - .num_threads(threads) - .build()?; - - pool.install(|| files::reencode_files(conn, hanlder))?; + files::reencode_files(conn, hanlder, threads)?; } Ok::<(), anyhow::Error>(()) } |
