golang中的并行处理

Question

给出以下代码:

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=%d\n", goroutine, loopindex)
}

我可以假设'dowork'函数将并行执行吗？

这是实现并行性的正确方法还是更好地使用渠道并为每个goroutine分离"dowork"工作者？

Answer 1

您的代码将同时运行,但不能并行运行.您可以通过设置使其并行运行GOMAXPROCS; 有关摘要,请参阅文章https://www.ardanlabs.com/blog/2014/01/concurrency-goroutines-and-gomaxprocs.html.

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

Answer 2

关于GOMAXPROCS,您可以在Go 1.5的发布文档中找到它:

默认情况下,Go程序在GOMAXPROCS设置为可用核心数的情况下运行; 在之前的版本中,它默认为1.

关于防止main函数立即退出,你可以利用它WaitGroup的Wait功能.

我编写了这个实用程序函数来帮助并行化一组函数:

import "sync"

// Parallelize parallelizes the function calls
func Parallelize(functions ...func()) {
    var waitGroup sync.WaitGroup
    waitGroup.Add(len(functions))

    defer waitGroup.Wait()

    for _, function := range functions {
        go func(copy func()) {
            defer waitGroup.Done()
            copy()
        }(function)
    }
}

所以在你的情况下,我们可以做到这一点

func1 := func() {
    f(0)
}

func2 = func() {
    f(1)
}

func3 = func() {
    f(2)
}

Parallelize(func1, func2, func3)

如果您想使用Parallelize功能,可以在https://github.com/shomali11/util找到它