代码之家 › 专栏 › 技术社区 › overexchange

如何等待go例程完成?

goroutine go

overexchange · 技术社区 · 4 年前

以下是场景:

inputCh := g(abc) // return <- chan []string


slice := make([]map[string][]string, 0)
m := sync.Mutex{}
for whatever := range inputCh {
    go func(whatever []string) {
        matches := f(xyz, whatever) // returns map[string][]string
        m.Lock()
        slice = append(slice, matches)
        m.Unlock()
    }(whatever)
}

z := merge(slice...)

inputCh close(inputCh) )

merge(slice...) 只有在所有的围棋程序完成并更新之后 slice

不确定,如果 sync.WaitGroup 可以使用。

如何保证 合并(切片…) 仅在 片 被所有围棋程序更新?

0 回复 | 直到 4 年前

kozmo 4 年前

使用 sync.WaitGroup 检查通道何时关闭

var wg sync.WaitGroup

for {
    whatever, ok := <-inputCh
    if !ok { // check inputCh is close
        break
    }
    // add delta
    wg.Add(1)
    go func(whatever []string) {
        matches := f(xyz, whatever)
        m.Lock()
        slice = append(slice, matches)
        m.Unlock()
        // goroutine is done
        wg.Done()
    }(whatever)
}

// waits until all the goroutines call "wg.Done()"
wg.Wait()

-3

M. Ekin Uygur 4 年前

你可以用 sync.WaitGroup

// create a work group
var wg sync.WaitGroup
// add delta
wg.Add(len(inputCh))

slice := make([]map[string][]string, 0)
m := sync.Mutex{}
for whatever := range inputCh {
    go func(whatever []string) {
        matches := f(xyz, whatever) // returns map[string][]string
        m.Lock()
        slice = append(slice, matches)
        m.Unlock()
        // signal work group that the routine is done
        wg.Done()
    }(whatever)
}
// waits until all the go routines call wg.Done()
wg.Wait()

推荐文章

ginad · 如何在go-app组件中执行javascript代码

4 月前

Jason Fingar · 方法在另一个方法的上下文中不可访问

5 月前

Flissi Hamed · 从抓取aliexpress到使用chromedp的无头浏览器

5 月前

Adam Presley · GORM错误:“运算符不存在:bigint=text”

6 月前

Jess The Witch · GCP云功能中处理延迟任务的模式

6 月前

Moonlit · 在Golang中将`func()Foo`转换为`func)any`?

6 月前

pmoubed · 这是使用计时器的goroutine泄漏吗?

6 月前

Kurt Peek · 在Go模板中,如何仅在字符串值非空的情况下添加一行?

6 月前

Harimbola Santatra · 如何获取JSON中包含unicode代码点的键的值?

6 月前

techStud · 为什么Go在变量超出作用域后立即取消引用悬挂指针时不会抛出错误?

6 月前