Goroutine 花费与 for 循环相同的时间来执行我的函数

Question

我有一个创建 Istio VirtualService 对象的函数。 我正在使用 goroutines 来同时执行我的功能，启动 100 个工人。

            var data map[string]string
            for _, data = range MapList {
                wg.Add(1)
                limit.Execute(func() {
                    go func(data map[string]string) {
                        defer wg.Done()
                        _,_ = m.createVirtualServices(ctx, data, namespace)
                    }(data)
                })
                wg.Wait()
            }

如果我只是遍历 seMapList 并执行我的函数，这将花费完全相同的时间来执行。

为什么？

Answer 1

因为您正在等待 goroutine 在启动后立即完成。试试这个：

            for _, data = range MapList {
                wg.Add(1)
                limit.Execute(func() {
                    go func(data map[string]string) {
                        defer wg.Done()
                        _,_ = m.createVirtualServices(ctx, data, namespace)
                    }(data)
                })
            }
            wg.Wait() // Wait for them after all goroutines are created

Answer 2

@Burak Serdan 的答案是正确的，但在这种情况下可能不是。从我看到你将匿名函数传递给limit.Execute，所以你的匿名函数将真正启动新的goroutine，但不会立即启动，但在limit.Execute 之后会在内部某处调用这个匿名函数。

但是你可以传递一个函数，而不是传递 N 个匿名函数，然后这个函数会运行 N 个 goroutines

var data map[string]string

limit.Execute(func() {
    for _, data = range MapList {
        wg.Add(1)
        go func(data map[string]string) {
            defer wg.Done()
            _,_ = m.createVirtualServices(ctx, data, namespace)
        }(data)
    }
})
wg.Wait()