From a82933a7a8324febaa1f81cd3feec9387f3a6171 Mon Sep 17 00:00:00 2001 From: lbl <1791778603@qq.com> Date: Tue, 23 Sep 2025 09:27:54 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E8=BF=90=E8=A1=8C=E6=97=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- vnt/src/port_mapping/mod.rs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/vnt/src/port_mapping/mod.rs b/vnt/src/port_mapping/mod.rs index 33354cc..dccb8cd 100644 --- a/vnt/src/port_mapping/mod.rs +++ b/vnt/src/port_mapping/mod.rs @@ -66,11 +66,7 @@ pub fn start_port_mapping( if vec.is_empty() { return Ok(()); } - let runtime = tokio::runtime::Builder::new_multi_thread() - .enable_all() - .thread_name("portMapping") - .build()?; - runtime.block_on(start_port_mapping0(vec))?; + let (sender, receiver) = tokio::sync::oneshot::channel::<()>(); let worker = stop_manager.add_listener("portMapping".into(), move || { let _ = sender.send(()); @@ -78,6 +74,11 @@ pub fn start_port_mapping( thread::Builder::new() .name("portMapping".into()) .spawn(move || { + let runtime = tokio::runtime::Builder::new_multi_thread() + .enable_all() + .thread_name("portMapping") + .build().unwrap(); + runtime.block_on(start_port_mapping0(vec)).unwrap(); runtime.block_on(async { let _ = receiver.await; });