Промежуточный коммит
This commit is contained in:
parent
bede26dbd0
commit
a69edcda42
@ -22,13 +22,13 @@ func Run(tasks []Task, n int, m int) error {
|
|||||||
for g := 1; g <= n && i+g < len(tasks); g++ {
|
for g := 1; g <= n && i+g < len(tasks); g++ {
|
||||||
wg.Add(1)
|
wg.Add(1)
|
||||||
go func(rt Task, errs *Errors) {
|
go func(rt Task, errs *Errors) {
|
||||||
|
defer wg.Done()
|
||||||
err := rt
|
err := rt
|
||||||
if err != nil {
|
if err != nil {
|
||||||
errs.mx.Lock()
|
errs.mx.Lock()
|
||||||
errs.count++
|
errs.count++
|
||||||
errs.mx.Unlock()
|
errs.mx.Unlock()
|
||||||
}
|
}
|
||||||
wg.Done()
|
|
||||||
}(tasks[i+g], &errs)
|
}(tasks[i+g], &errs)
|
||||||
}
|
}
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
|
Loading…
x
Reference in New Issue
Block a user