go - 在 Go 中定期调用 N 个并发函数的最佳方法是什么？

Question

过去一天左右，我一直在努力解决一个问题，以找出创建 N 个并发函数的最佳方法，这些函数在 Go 中以相同的时间间隔定期调用。我希望能够指定任意数量的函数，让它们全部同时定期运行，并在指定的时间后全部结束。

现在我有一个可行的解决方案，但必须为每个并发函数创建一个新的自动收报机。我也不确定如何正确使用 sync.WaitGroup，因为我当前的实现导致程序永无止境(最后卡在 wg.Wait() 上)

我简要地查看了一个名为 Multitick 的代码包装器，但我不确定如何实现它。也许 Multitick 可以成为这里的解决方案？

func main() {
    N := 10

    var wg sync.WaitGroup
    wg.Add(N)

    quit := make(chan struct{})

    for i := 0; i < N; i++ {

        tick := time.NewTicker(500 * time.Millisecond)
        go func(t *time.Ticker) {

            for a := range tick.C {

                select {
                case <-quit:
                    break
                default:
                    fmt.Println(a) // do something on tick
                }
            }
            wg.Done()
        }(tick)
    }

    time.Sleep(10 * time.Second)
    close(quit)
    wg.Wait()
}

Go Playground Demo

所以这个解决方案有效，以适当的时间间隔同时执行所有代码并在 10 秒后完成，但它实际上并没有退出程序，而是在最后卡在 wg.Wait() 行上。此外，每个并发函数调用都使用自己的自动收报机 - 有什么方法可以让所有函数都从一个“主”自动收报机运行吗？

提前致谢!这是我第一次真正深入研究 Go 中的并发。

Answer 1

你的程序永远不会退出的原因是 Go 语言的一个奇怪的怪癖:break case <-quit 的声明退出 select语句，而不是循环。 (不确定为什么这种行为会有用。)要修复您的程序，您需要明确地打破循环:

tickLoop:
    for a := range tick.C {
        select {
        case <-quit:
            break tickLoop
        default:
            fmt.Println(a, "function #", id) // do something on tick
        }
    }

在编写代码时，它总是等到下一个滴答声才退出。您可以通过阅读 tick.C 来解决这个问题在 select 语句中也是:

tickLoop:
    for {
        select {
        case <-quit:
            break tickLoop
        case a := <-tick.C:
            fmt.Println(a, "function #", id) // do something on tick
        }
    }

最后，如果你想重组你的程序只使用一个代码，你可以启动一个额外的 goroutine，它监听代码和 quit。 channel ，然后开始 N每个 tick 上的子 goroutines。