From f41c45a36bb9d20ba741ce353e792cd411cdb38d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=A1=A5=E4=B8=8B=E7=BA=A2=E8=8D=AF?= <ai121@foxmail.com>
Date: Sat, 17 Jan 2026 19:06:05 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=86=85=E5=AD=98=E6=B3=84?=
 =?UTF-8?q?=E9=9C=B2?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/scheduler.rs | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/scheduler.rs b/src/scheduler.rs
index 91e6548..d83e3f5 100644
--- a/src/scheduler.rs
+++ b/src/scheduler.rs
@@ -72,6 +72,7 @@ impl MetadataScheduler {
             let queue_len = self.queue_len.clone();
             
             tokio::spawn(async move {
+                #[cfg(debug_assertions)]
                 log::trace!("Worker {} 启动", worker_id);
                 
                 loop {
@@ -154,6 +155,11 @@ impl MetadataScheduler {
                 }
             }
         }
+        
+        // 显式关闭 task_tx，让所有 worker 任务能够退出
+        drop(task_tx);
+        #[cfg(debug_assertions)]
+        log::trace!("MetadataScheduler 主循环退出，等待 worker 任务完成");
     }
     
     async fn process_hash(