加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 大数据 > 正文

并行处理 – 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以获得一个很好的总结.

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

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读