From 2fc103d2af6349b408633ac673269db434b76866 Mon Sep 17 00:00:00 2001 From: "Aode (Lion)" Date: Thu, 24 Feb 2022 18:34:00 -0600 Subject: [PATCH] Name jive threads --- src/runtime.rs | 30 ++++++++++++++++++++---------- 1 file changed, 20 insertions(+), 10 deletions(-) diff --git a/src/runtime.rs b/src/runtime.rs index ca758f8..ad965cf 100644 --- a/src/runtime.rs +++ b/src/runtime.rs @@ -134,26 +134,36 @@ impl RuntimeState { let executor = executor.clone(); let blocking = blocking.clone(); - thread_handles.push(std::thread::spawn(move || { - let token = RuntimeState::install(&executor, &blocking); + thread_handles.push( + std::thread::Builder::new() + .name("jive:executor".into()) + .spawn(move || { + let token = RuntimeState::install(&executor, &blocking); - let _ = foxtrot::block_on(executor.into_runner()).unwrap(); + let _ = foxtrot::block_on(executor.into_runner()).unwrap(); - drop(token); - })); + drop(token); + }) + .unwrap(), + ); } for _ in 0..builder.blocking_count { let executor = executor.clone(); let blocking = blocking.clone(); - thread_handles.push(std::thread::spawn(move || { - let token = RuntimeState::install(&executor, &blocking); + thread_handles.push( + std::thread::Builder::new() + .name("jive:blocking".into()) + .spawn(move || { + let token = RuntimeState::install(&executor, &blocking); - let _ = blocking.block_on(pending::<()>()); + let _ = blocking.block_on(pending::<()>()); - drop(token); - })); + drop(token); + }) + .unwrap(), + ); } Runtime {