|
@@ -147,10 +147,8 @@ const defaultNumWorkers = 10
|
|
|
func (job *workerPoolJob[I, O]) withWorkers(workers int) *workerPoolJob[I, O] {
|
|
|
if workers == 0 {
|
|
|
job.workers = defaultNumWorkers
|
|
|
- } else if workers > len(job.data) {
|
|
|
- job.workers = len(job.data)
|
|
|
} else {
|
|
|
- job.workers = workers
|
|
|
+ job.workers = min(workers, len(job.data))
|
|
|
}
|
|
|
|
|
|
return job
|