Skip to content

Commit

Permalink
Stop using joins on handles in aspen
Browse files Browse the repository at this point in the history
  • Loading branch information
kylerchin committed Apr 24, 2024
1 parent 5c9fc37 commit 551b06a
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 8 deletions.
6 changes: 3 additions & 3 deletions src/aspen/async_threads_alpenrose.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down
5 changes: 0 additions & 5 deletions src/aspen/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 551b06a

Please sign in to comment.