summaryrefslogtreecommitdiff
path: root/vendor/github.com/testcontainers/testcontainers-go/parallel.go
diff options
context:
space:
mode:
authormo khan <mo@mokhan.ca>2025-07-08 13:11:59 -0600
committermo khan <mo@mokhan.ca>2025-07-21 15:20:39 -0600
commit2ddcc34ca455973598f5693d64103deea41d8d79 (patch)
tree0b3a42aa97bca93c15c67a679c903611e5ab60c1 /vendor/github.com/testcontainers/testcontainers-go/parallel.go
parent16c27cd885b9c0d1241dfead3120643f0e8c556c (diff)
chore: use minit to start processes from Procfile
Diffstat (limited to 'vendor/github.com/testcontainers/testcontainers-go/parallel.go')
-rw-r--r--vendor/github.com/testcontainers/testcontainers-go/parallel.go7
1 files changed, 2 insertions, 5 deletions
diff --git a/vendor/github.com/testcontainers/testcontainers-go/parallel.go b/vendor/github.com/testcontainers/testcontainers-go/parallel.go
index 0349023..a75d011 100644
--- a/vendor/github.com/testcontainers/testcontainers-go/parallel.go
+++ b/vendor/github.com/testcontainers/testcontainers-go/parallel.go
@@ -61,10 +61,7 @@ func ParallelContainers(ctx context.Context, reqs ParallelContainerRequest, opt
opt.WorkersCount = defaultWorkersCount
}
- tasksChanSize := opt.WorkersCount
- if tasksChanSize > len(reqs) {
- tasksChanSize = len(reqs)
- }
+ tasksChanSize := min(opt.WorkersCount, len(reqs))
tasksChan := make(chan GenericContainerRequest, tasksChanSize)
resultsChan := make(chan parallelContainersResult, tasksChanSize)
@@ -74,7 +71,7 @@ func ParallelContainers(ctx context.Context, reqs ParallelContainerRequest, opt
wg.Add(tasksChanSize)
// run workers
- for i := 0; i < tasksChanSize; i++ {
+ for range tasksChanSize {
go parallelContainersRunner(ctx, tasksChan, resultsChan, &wg)
}