并行处理 – golang中的并行处理
发布时间:2020-12-16 19:29:38 所属栏目:大数据 来源:网络整理
导读:给出以下代码: package mainimport ( "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
|
给出以下代码:
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=%dn",goroutine,loopindex)
}
我可以假设’dowork’函数将并行执行吗? 这是实现并行性的正确方法还是更好地使用渠道并为每个goroutine分离“dowork”工作者?
您的代码将同时运行,但不能并行运行.您可以通过设置GOMAXPROCS使其并行运行;请参阅文章
https://www.ardanlabs.com/blog/2014/01/concurrency-goroutines-and-gomaxprocs.html以获得一个很好的总结.
目前还不清楚你在这里想要完成什么,但它看起来像是一种非常有效的方式来实现我的并发性. (编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |
