Fix bug: deadlock when files are under 5 lines due to regression

zeddo123 · Aug 31, 2023 · 4777dfb · 4777dfb
1 parent 31aa6c0
commit 4777dfb
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/files/file.go b/files/file.go
@@ -57,7 +57,7 @@ func filterColumnsAsync(bytes []byte, targetCols []string, csvDelimiter string)
 
 	jobchan := make(chan string, len(lines))
 	resultschan := make(chan string, len(lines))
-	for id := 0; id < int(math.Round(float64(len(lines)) * 0.10)); id++ {
+	for id := 0; id < int(math.Round(float64(len(lines)) * 0.5)); id++ {
 		go Line.ProcessLineWorker(id, jobchan, resultschan, indexCols, csvDelimiter)
 	}
 
@@ -71,6 +71,7 @@ func filterColumnsAsync(bytes []byte, targetCols []string, csvDelimiter string)
 	for i := 0; i < len(lines); i++ {
 		ls = append(ls, <-resultschan)
 	}
+	close(resultschan)
 	return strings.Join(ls, "\n")
 }