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

如何在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.

    已采纳该答案
    评论
    解决 无用
    打赏 举报

相关推荐 更多相似问题