give tokio threads a more convenient name for monitoring purposes

This commit is contained in:
James Wilson
2021-08-09 11:36:46 +01:00
parent b22efc804a
commit 9f76fabaed
3 changed files with 3 additions and 0 deletions
@@ -33,6 +33,7 @@ pub fn benchmark_subscribe_speed(c: &mut Criterion) {
}, },
CoreOpts { CoreOpts {
worker_threads: Some(16), worker_threads: Some(16),
num_aggregators: Some(1),
..Default::default() ..Default::default()
}, },
ShardOpts { ShardOpts {
+1
View File
@@ -98,6 +98,7 @@ fn main() {
tokio::runtime::Builder::new_multi_thread() tokio::runtime::Builder::new_multi_thread()
.enable_all() .enable_all()
.worker_threads(worker_threads) .worker_threads(worker_threads)
.thread_name("telemetry_core_worker")
.build() .build()
.unwrap() .unwrap()
.block_on(async { .block_on(async {
+1
View File
@@ -107,6 +107,7 @@ fn main() {
tokio::runtime::Builder::new_multi_thread() tokio::runtime::Builder::new_multi_thread()
.enable_all() .enable_all()
.worker_threads(worker_threads) .worker_threads(worker_threads)
.thread_name("telemetry_shard_worker")
.build() .build()
.unwrap() .unwrap()
.block_on(async { .block_on(async {