1 aggregator loop by default for now

This commit is contained in:
James Wilson
2021-08-09 10:13:10 +01:00
parent c469ef8dfe
commit 626fe95d89
+3 -3
View File
@@ -90,9 +90,9 @@ fn main() {
let num_aggregators = match opts.num_aggregators { let num_aggregators = match opts.num_aggregators {
Some(0) => num_cpus::get(), Some(0) => num_cpus::get(),
Some(n) => n, Some(n) => n,
// By default, we'll have half as many aggregator tasks // For now, we just have 1 aggregator loop by default,
// running as we do worker threads (minimum 1). // but we may want to be smarter here eventually.
None => usize::max(worker_threads / 2, 1), None => 1,
}; };
tokio::runtime::Builder::new_multi_thread() tokio::runtime::Builder::new_multi_thread()