Skip to content

Commit 5bd512e

Browse files
we spawn three threads per chunk
1 parent 17d611e commit 5bd512e

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

benches/extract.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ fn extract_split(bench: &mut Bencher) {
6060
.unwrap();
6161

6262
let params = ExtractionParameters {
63-
decompression_threads: num_cpus::get(),
63+
decompression_threads: num_cpus::get() / 3,
6464
..Default::default()
6565
};
6666

src/read/pipelining.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -752,7 +752,7 @@ pub mod split_extraction {
752752
/* NB: this will perform a syscall. We still probably want to call this dynamically
753753
* instead of globally caching the call, in order to respect the dynamic value of
754754
* e.g. sched affinity. */
755-
decompression_threads: num_cpus::get(),
755+
decompression_threads: num_cpus::get() / 3,
756756
decompression_copy_buffer_length: 1024 * 1024,
757757
file_range_copy_buffer_length: 1024 * 1024,
758758
#[cfg(not(target_os = "linux"))]

0 commit comments

Comments
 (0)