From b3daf697494c3d89bc932fb6e3a036d8a30130ed Mon Sep 17 00:00:00 2001 From: karencfv Date: Wed, 16 Jul 2025 11:21:52 +1200 Subject: [PATCH] [clickhouse-admin] use a smaller tokio worker pool --- clickhouse-admin/src/bin/clickhouse-admin-keeper.rs | 4 +++- clickhouse-admin/src/bin/clickhouse-admin-server.rs | 4 +++- clickhouse-admin/src/bin/clickhouse-admin-single.rs | 4 +++- 3 files changed, 9 insertions(+), 3 deletions(-) diff --git a/clickhouse-admin/src/bin/clickhouse-admin-keeper.rs b/clickhouse-admin/src/bin/clickhouse-admin-keeper.rs index 51242e20d9..692f17ec50 100644 --- a/clickhouse-admin/src/bin/clickhouse-admin-keeper.rs +++ b/clickhouse-admin/src/bin/clickhouse-admin-keeper.rs @@ -40,7 +40,9 @@ enum Args { } fn main() { - if let Err(err) = oxide_tokio_rt::run(main_impl()) { + let mut builder = oxide_tokio_rt::Builder::new_multi_thread(); + builder.worker_threads(8); + if let Err(err) = oxide_tokio_rt::run_builder(&mut builder, main_impl()) { fatal(err); } } diff --git a/clickhouse-admin/src/bin/clickhouse-admin-server.rs b/clickhouse-admin/src/bin/clickhouse-admin-server.rs index 83b3a53819..9e204bacdb 100644 --- a/clickhouse-admin/src/bin/clickhouse-admin-server.rs +++ b/clickhouse-admin/src/bin/clickhouse-admin-server.rs @@ -40,7 +40,9 @@ enum Args { } fn main() { - if let Err(err) = oxide_tokio_rt::run(main_impl()) { + let mut builder = oxide_tokio_rt::Builder::new_multi_thread(); + builder.worker_threads(8); + if let Err(err) = oxide_tokio_rt::run_builder(&mut builder, main_impl()) { fatal(err); } } diff --git a/clickhouse-admin/src/bin/clickhouse-admin-single.rs b/clickhouse-admin/src/bin/clickhouse-admin-single.rs index 4acd612122..8cd185d159 100644 --- a/clickhouse-admin/src/bin/clickhouse-admin-single.rs +++ b/clickhouse-admin/src/bin/clickhouse-admin-single.rs @@ -39,7 +39,9 @@ enum Args { } fn main() { - if let Err(err) = oxide_tokio_rt::run(main_impl()) { + let mut builder = oxide_tokio_rt::Builder::new_multi_thread(); + builder.worker_threads(8); + if let Err(err) = oxide_tokio_rt::run_builder(&mut builder, main_impl()) { fatal(err); } }