Skip to content

Commit 41f8eea

Browse files
authored
[clickhouse-admin] Use a smaller tokio worker pool (#8604)
Follow up from #8555 (comment) and #8599
1 parent dbc7b8e commit 41f8eea

File tree

3 files changed

+9
-3
lines changed

3 files changed

+9
-3
lines changed

clickhouse-admin/src/bin/clickhouse-admin-keeper.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,9 @@ enum Args {
4040
}
4141

4242
fn main() {
43-
if let Err(err) = oxide_tokio_rt::run(main_impl()) {
43+
let mut builder = oxide_tokio_rt::Builder::new_multi_thread();
44+
builder.worker_threads(8);
45+
if let Err(err) = oxide_tokio_rt::run_builder(&mut builder, main_impl()) {
4446
fatal(err);
4547
}
4648
}

clickhouse-admin/src/bin/clickhouse-admin-server.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,9 @@ enum Args {
4040
}
4141

4242
fn main() {
43-
if let Err(err) = oxide_tokio_rt::run(main_impl()) {
43+
let mut builder = oxide_tokio_rt::Builder::new_multi_thread();
44+
builder.worker_threads(8);
45+
if let Err(err) = oxide_tokio_rt::run_builder(&mut builder, main_impl()) {
4446
fatal(err);
4547
}
4648
}

clickhouse-admin/src/bin/clickhouse-admin-single.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,9 @@ enum Args {
3939
}
4040

4141
fn main() {
42-
if let Err(err) = oxide_tokio_rt::run(main_impl()) {
42+
let mut builder = oxide_tokio_rt::Builder::new_multi_thread();
43+
builder.worker_threads(8);
44+
if let Err(err) = oxide_tokio_rt::run_builder(&mut builder, main_impl()) {
4345
fatal(err);
4446
}
4547
}

0 commit comments

Comments
 (0)