Don't limit on the number of waiting-to-display processes

Author: karolba

go.mod

@@ -11,6 +11,7 @@ require (
 	github.com/pkg/term v1.2.0-beta.2
 	github.com/shirou/gopsutil/v3 v3.23.8
 	github.com/spf13/pflag v1.0.5
+	golang.design/x/chann v0.1.2
 	golang.org/x/exp v0.0.0-20230905200255-921286631fa9
 	golang.org/x/sys v0.12.0
 	golang.org/x/term v0.12.0
@@ -27,3 +28,6 @@ require (
 	github.com/tklauser/numcpus v0.6.1 // indirect
 	github.com/yusufpapurcu/wmi v1.2.3 // indirect
 )
+
+// https://github.com/golang-design/chann/pull/5
+replace golang.design/x/chann v0.1.2 => github.com/amyangfei/chann v0.0.0-20230110021018-bca7d685828c

go.sum

@@ -1,5 +1,7 @@
 github.com/alessio/shellescape v1.4.2 h1:MHPfaU+ddJ0/bYWpgIeUnQUqKrlJ1S7BfEYPM4uEoM0=
 github.com/alessio/shellescape v1.4.2/go.mod h1:PZAiSCk0LJaZkiCSkPv8qIobYglO3FPpyFjDCtHLS30=
+github.com/amyangfei/chann v0.0.0-20230110021018-bca7d685828c h1:4tmBsdlMK6MWi6sgiWxazvQb2KCAyudUvq2cOg06xag=
+github.com/amyangfei/chann v0.0.0-20230110021018-bca7d685828c/go.mod h1:Rh5KhCAp+0qu9+FfKPymHpu8onmjl89sFwMeiw3SK14=
 github.com/creack/pty v1.1.18 h1:n56/Zwd5o6whRC5PMGretI4IdRLlmBXYNjScPaBgsbY=
 github.com/creack/pty v1.1.18/go.mod h1:MOBLtS5ELjhRRrroQr9kyvTxUAFNvYEK993ew/Vr4O4=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

main.go

@@ -19,6 +19,7 @@ import (
 	"github.com/fatih/color"
 	"github.com/mattn/go-isatty"
 	"github.com/pkg/term/termios"
+	"golang.design/x/chann"
 	"golang.org/x/exp/slices"
 	"golang.org/x/term"
 )
@@ -296,23 +297,22 @@ func main() {
 		}
 	}
 
-	// TODO: there's now basically no limit with flRecursiveProcessLimit being false
-	processes := make(chan *ProcessResult, 32*1024)
+	processes := chann.New[*ProcessResult]()
 	go func() {
-		defer close(processes)
+		defer processes.Close()
 
 		if *flQueueWait {
-			startProcessesFromQueue(processes)
+			startProcessesFromQueue(processes.In())
 			return
 		}
 
 		if args.hasTripleColon {
-			startProcessesFromCliArguments(args, processes)
+			startProcessesFromCliArguments(args, processes.In())
 		}
 		if *flFromStdin {
-			startProcessesFromStdin(args, processes)
+			startProcessesFromStdin(args, processes.In())
 		}
 	}()
 
-	os.Exit(displaySequentially(processes))
+	os.Exit(displaySequentially(processes.Out()))
 }