fix gbatch

snail007 · Feb 4, 2025 · e73d35f · e73d35f
1 parent c52e34e
commit e73d35f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/util/batch/batch.go b/util/batch/batch.go
@@ -108,7 +108,7 @@ func (s *Executor) waitFirst(checkSuccess bool) (value interface{}, err error) {
 	if len(s.tasks) == 0 {
 		return nil, errors.New("tasks is empty")
 	}
-	waitChan := make(chan taskResult, 1)
+	waitChan := make(chan taskResult)
 	allResult := glist.New()
 	p := gpool.New(s.workers)
 	defer p.Stop()