代码拉取完成,页面将自动刷新
/*
Copyright IBM Corp. All Rights Reserved.
SPDX-License-Identifier: Apache-2.0
*/
package statecouchdb
import (
"sync"
"github.com/pkg/errors"
)
// batch is executed in a separate goroutine.
type batch interface {
execute() error
}
// executeBatches executes each batch in a separate goroutine and returns error if
// any of the batches return error during its execution
func executeBatches(batches []batch) error {
logger.Debugf("Executing batches = %s", batches)
numBatches := len(batches)
if numBatches == 0 {
return nil
}
if numBatches == 1 {
return batches[0].execute()
}
var batchWG sync.WaitGroup
batchWG.Add(numBatches)
errsChan := make(chan error, numBatches)
defer close(errsChan)
for _, b := range batches {
go func(b batch) {
defer batchWG.Done()
if err := b.execute(); err != nil {
errsChan <- err
}
}(b)
}
batchWG.Wait()
select {
case err := <-errsChan:
return errors.WithStack(err)
default:
return nil
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。