From 551b06a90b40056f46edf206c3ac4eb9ed2dc3ba Mon Sep 17 00:00:00 2001 From: Kyler Chin <7539174+kylerchin@users.noreply.github.com> Date: Tue, 23 Apr 2024 18:33:38 -0700 Subject: [PATCH] Stop using joins on handles in aspen --- src/aspen/async_threads_alpenrose.rs | 6 +++--- src/aspen/main.rs | 5 ----- 2 files changed, 3 insertions(+), 8 deletions(-) diff --git a/src/aspen/async_threads_alpenrose.rs b/src/aspen/async_threads_alpenrose.rs index 5a9630bc..2ffc4d9a 100644 --- a/src/aspen/async_threads_alpenrose.rs +++ b/src/aspen/async_threads_alpenrose.rs @@ -38,9 +38,9 @@ pub async fn alpenrose_process_threads( })); } - for handle in handler_vec.into_iter() { - handle.join().unwrap().await; - } + //for handle in handler_vec.into_iter() { + //handle.join().unwrap().await; + // } } pub async fn alpenrose_loop_process_thread( diff --git a/src/aspen/main.rs b/src/aspen/main.rs index 0d5f06eb..4b82fc77 100644 --- a/src/aspen/main.rs +++ b/src/aspen/main.rs @@ -228,11 +228,6 @@ async fn main() -> anyhow::Result<()> { } }); - join!( - async_from_alpenrose_processor_handler.join().unwrap(), - leader_thread_handler.join().unwrap() - ); - println!("Listening on port {}", listener.local_addr().port()); listener