perf: Increase default async thread count for low core count systems (#…

…19829)
pola-rs · Nov 17, 2024 · 2a0d79b · 2a0d79b
1 parent 245d549
commit 2a0d79b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/crates/polars-io/src/pl_async.rs b/crates/polars-io/src/pl_async.rs
@@ -262,7 +262,7 @@ impl RuntimeManager {
     fn new() -> Self {
         let n_threads = std::env::var("POLARS_ASYNC_THREAD_COUNT")
             .map(|x| x.parse::<usize>().expect("integer"))
-            .unwrap_or((POOL.current_num_threads() / 4).clamp(1, 4));
+            .unwrap_or(POOL.current_num_threads().clamp(1, 4));
 
         if polars_core::config::verbose() {
             eprintln!("Async thread count: {}", n_threads);