diff --git a/server/internal/service/delivery_task_test.go b/server/internal/service/delivery_task_test.go index 77c5ea4..b1f2b2f 100644 --- a/server/internal/service/delivery_task_test.go +++ b/server/internal/service/delivery_task_test.go @@ -354,14 +354,14 @@ func TestSubscribeTask_ConcurrentSafety(t *testing.T) { const goroutines = 50 // 并发订阅 - cancels := make([]func(), 0, goroutines) + cancels := make([]func(), goroutines) for i := 0; i < goroutines; i++ { wg.Add(1) - go func() { + go func(idx int) { defer wg.Done() _, cancel := svc.SubscribeTask(taskID) - cancels = append(cancels, cancel) - }() + cancels[idx] = cancel + }(i) } wg.Wait()