fix: potential deadlock when executing commands in parallel

kernle32dll · Apr 14, 2020 · bc85f52 · bc85f52
1 parent 610a4fc
commit bc85f52
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/internal/cmd/cmd_any.go b/internal/cmd/cmd_any.go
@@ -80,12 +80,16 @@ func (c AnyCommand) Execute() error {
 
 func (c AnyCommand) executeParallel(paths []string) {
 	parallelFactor := runtime.NumCPU()
-	in := make(chan int, len(paths))
-	out := make([]chan io.ReadCloser, len(paths))
+	in := make(chan int, parallelFactor)
+	out := make([]chan *io.PipeReader, len(paths))
 	for i := range paths {
-		out[i] = make(chan io.ReadCloser, 1)
-		in <- i
+		out[i] = make(chan *io.PipeReader, 1)
 	}
+	go func() {
+		for i := range paths {
+			in <- i
+		}
+	}()
 
 	for i := 0; i < parallelFactor; i++ {
 		go func() {