并行处理 – golang中的并行处理

给出以下代码：

package main

import (
    "fmt"
    "math/rand"
    "time"
)

func main() {
    for i := 0; i < 3; i++ {
        go f(i)
    }

    // prevent main from exiting immediately
    var input string
    fmt.Scanln(&input)
}

func f(n int) {
    for i := 0; i < 10; i++ {
        dowork(n,i)
        amt := time.Duration(rand.Intn(250))
        time.Sleep(time.Millisecond * amt)
    }
}

func dowork(goroutine,loopindex int) {
    // simulate work
    time.Sleep(time.Second * time.Duration(5))
    fmt.Printf("gr[%d]: i=%d\n",goroutine,loopindex)
}

我可以假设’dowork’函数将并行执行吗？

这是实现并行性的正确方法还是更好地使用渠道并为每个goroutine分离“dowork”工作者？

您的代码将同时运行,但不能并行运行.您可以通过设置GOMAXPROCS使其并行运行;请参阅文章 https://www.ardanlabs.com/blog/2014/01/concurrency-goroutines-and-gomaxprocs.html以获得一个很好的总结.

目前还不清楚你在这里想要完成什么,但它看起来像是一种非常有效的方式来实现我的并发性.