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.

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

报告相同问题?

悬赏问题

  • ¥100 需要跳转番茄畅听app的adb命令
  • ¥50 寻找一位有逆向游戏盾sdk 应用程序经验的技术
  • ¥15 请问有用MZmine处理 “Waters SYNAPT G2-Si QTOF质谱仪在MSE模式下采集的非靶向数据” 的分析教程吗
  • ¥50 opencv4nodejs 如何安装
  • ¥15 adb push异常 adb: error: 1409-byte write failed: Invalid argument
  • ¥15 nginx反向代理获取ip,java获取真实ip
  • ¥15 eda:门禁系统设计
  • ¥50 如何使用js去调用vscode-js-debugger的方法去调试网页
  • ¥15 376.1电表主站通信协议下发指令全被否认问题
  • ¥15 物体双站RCS和其组成阵列后的双站RCS关系验证