dsdxlibt98300 2017-04-18 16:38
浏览 73
已采纳

如何在Go中并行调用函数

I am trying to run a function in parallel.... when I do it

func runParallel() {
    var out [5]chan string
    for i := range out {
        out[i] = make(chan string)
    }
    for j:=0; j<2; j++ {
        fmt.Println("
Starting: ", j)
        go func() {
            out[0] <- f3(4)
        }()

        fmt.Println(<-out[0])
    }
}

func main() {    
    runParallel()
}

I see that function gets called serially one after the other... but when i do..

func runParallel() {
    var out [5]chan string
    for i := range out {
        out[i] = make(chan string)
    }

    fmt.Println("
Starting: ", j)
    go func() {
        out[0] <- f3(4)
    }()
    go func() {
        out[0] <- f3(4)
    }()

    fmt.Println(<-out[0])
}

func main() {    
    runParallel()
}

The function gets called parallel.

I need to get the function called parallel in a for loop, Please help.

  • 写回答

1条回答 默认 最新

  • dpoxk64080 2017-04-18 17:01
    关注

    Keep in mind that goroutines provide concurrency, and concurrency is not parallelism.

    The problem in your first example is that you're reading from the unbuffered channel inside the for loop so the write that's happening in the goroutine is serialized waiting for the read. Move the read outside of the for loop, and/or put the read in it's own goroutine and you may see more parallelization.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥15 各位请问平行检验趋势图这样要怎么调整?说标准差差异太大了
  • ¥15 delphi webbrowser组件网页下拉菜单自动选择问题
  • ¥15 wpf界面一直接收PLC给过来的信号,导致UI界面操作起来会卡顿
  • ¥15 init i2c:2 freq:100000[MAIXPY]: find ov2640[MAIXPY]: find ov sensor是main文件哪里有问题吗
  • ¥15 运动想象脑电信号数据集.vhdr
  • ¥15 三因素重复测量数据R语句编写,不存在交互作用
  • ¥15 微信会员卡等级和折扣规则
  • ¥15 微信公众平台自制会员卡可以通过收款码收款码收款进行自动积分吗
  • ¥15 随身WiFi网络灯亮但是没有网络,如何解决?
  • ¥15 gdf格式的脑电数据如何处理matlab