Golang中的并行处理

  • Z时代
  • 2024-01-10
  • 分类：问答

给出以下代码：

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使用通道并将单独的“ workwork”工人分开更好？

回答：

关于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

以上是 Golang中的并行处理 的全部内容， 来源链接： utcz.com/qa/415873.html

回到顶部