一堆goroutine中的嵌套errgroup

问题描述

我对golang及其并发原则还很陌生。我的用例涉及对一批实体执行多个http请求（针对单个实体）。如果对实体的任何http请求均失败，则我需要停止对其的所有并行http请求。另外，我还必须管理因错误而失败的实体的数量。我正在尝试在实体goroutine中实现错误组，以便如果单个实体的任何http请求失败，则错误组将终止并将错误返回给其父goroutine。但是我不确定如何维护错误计数。

func main(entity[] string) {
    errorC := make(chan string) // channel to insert failed entity
    var wg sync.WaitGroup

    for _,link := range entity {
        wg.Add(1)
        // Spawn errorgroup here. errorgroup_spawn
    }

    go func() {
        wg.Wait()   
        close(errorC)    
    }()

    for msg := range errorC {
        // here storing error entityIds somewhere.
    }
}

和这样的错误组

func errorgroup_spawn(ctx context.Context,errorC chan string,wg *sync.WaitGroup) { // and other params
    defer (*wg).Done()
    
   goRoutineCollection,ctxx := errgroup.WithContext(ctx)
    results := make(chan *result)
    goRoutineCollection.Go(func() error {
        // http calls for single entity
        // if error occurs,push it in errorC,and return Error.
        return nil
    })

    go func() {
        goRoutineCollection.Wait()
        close(result)
    }()

   return goRoutineCollection.Wait()
}

PS：我还考虑过应用嵌套的错误组，但无法考虑在运行其他错误组时维护错误计数谁能指导我，这是处理这种现实情况的正确方法吗？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

go goroutine