From a3d7d1eccbf53f27892522627b454e7453e59a7f Mon Sep 17 00:00:00 2001
From: M09Ic <m09ician@gmail.com>
Date: Mon, 19 Jan 2026 18:02:18 +0800
Subject: [PATCH] fix: pool wg negative count

---
 core/pool/pool.go | 18 ++++++++----------
 1 file changed, 8 insertions(+), 10 deletions(-)

diff --git a/core/pool/pool.go b/core/pool/pool.go
index 523ad9c..baab583 100644
--- a/core/pool/pool.go
+++ b/core/pool/pool.go
@@ -48,17 +48,15 @@ func (pool *BasePool) addAddition(u *Unit) {
 	select {
 	case pool.additionCh <- u:
 	default:
+		// 强行屏蔽报错, 防止goroutine泄露
+		go func() {
+			select {
+			case pool.additionCh <- u:
+			case <-pool.ctx.Done():
+				pool.wg.Done()
+			}
+		}()
 	}
-	pool.wg.Add(1)
-	// 强行屏蔽报错, 防止goroutine泄露
-	go func() {
-		select {
-		case pool.additionCh <- u:
-			pool.wg.Done()
-		case <-pool.ctx.Done():
-			pool.wg.Done()
-		}
-	}()
 }
 
 func (pool *BasePool) putToOutput(bl *baseline.Baseline) {