Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom@tomclegg.ca>
}
go close(todo)
var tileJobs sync.WaitGroup
}
go close(todo)
var tileJobs sync.WaitGroup
- running := int64(runtime.NumCPU())
- for i := 0; i < runtime.NumCPU(); i++ {
+ var running int64
+ for i := 0; i < runtime.NumCPU()*9/8+1; i++ {
+ atomic.AddInt64(&running, 1)
go func() {
defer tileJobs.Done()
defer atomic.AddInt64(&running, -1)
go func() {
defer tileJobs.Done()
defer atomic.AddInt64(&running, -1)