当前位置： > > > > 以下实现是否使我的代码并行？

以下实现是否使我的代码并行？

来源：stackoverflow
2024-04-26 09:09:35
0浏览
收藏

知识点掌握了，还需要不断练习才能熟练运用。下面米云给大家带来一个Golang开发实战，手把手教大家学习《以下实现是否使我的代码并行？》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

问题内容

我在 go 中有一项任务，要并行化代码的给定循环。我不确定我的代码是否是并行的。

我尝试简单地将数组分成两半，并在两半上使用 go 例程。

package main

import (
    "fmt"
    "math"
)

type body struct {
    x, y, vx, vy, mass float64
    r, g, b uint
}

func main() {
    var count uint
    var radius float64
    done := make(chan bool)
    fmt.scan(&count, &radius)
    bodies := make([]body, count)
    for i := range bodies {
        b := &bodies[i]
        fmt.scan(&b.x, &b.y, &b.vx, &b.vy, &b.mass, &b.r, &b.g, &b.b)
    }

    updatedbodies := make([]body, count)
    copy(updatedbodies, bodies)
    mid := len(updatedbodies)/2


    go func(){
    for i := range updatedbodies[mid:] {
        b := &updatedbodies[i+mid]
        for _, ob := range bodies {
            dx, dy := ob.x - b.x, ob.y - b.y
            if dist := math.sqrt(dx*dx + dy*dy); dist > 1 { // far enough
                accel := 0.0000000000667 * ob.mass / (dist * dist * dist)
                b.vx += accel * dx
                b.vy += accel * dy
            }
        }
        b.x += b.vx
        b.y += b.vy

    }
    done <- true
}()
    go func(){
        for i := range updatedbodies[:mid] {
        b := &updatedbodies[i]
        for _, ob := range bodies {
            dx, dy := ob.x - b.x, ob.y - b.y
            if dist := math.sqrt(dx*dx + dy*dy); dist > 1 { // far enough
                accel := 0.0000000000667 * ob.mass / (dist * dist * dist)
                b.vx += accel * dx
                b.vy += accel * dy
            }
        }
        b.x += b.vx
        b.y += b.vy

    }
    done <- true
}()

    <- done
    <- done
    fmt.println(count)
    fmt.println(radius)
    for _, b := range updatedbodies {
        fmt.println(b.x, b.y, b.vx, b.vy, b.mass, b.r, b.g, b.b)
    }
}

for i := range updatedBodies {
        b := &updatedBodies[i]
        for _, ob := range bodies {
            dx, dy := ob.x - b.x, ob.y - b.y
            if dist := math.Sqrt(dx*dx + dy*dy); dist > 1 { // far enough
                accel := 0.0000000000667 * ob.mass / (dist * dist * dist)
                b.vx += accel * dx
                b.vy += accel * dy
            }
        }
        b.x += b.vx
        b.y += b.vy

    }

我向一位教授询问了他说我必须递归运行 go 例程才能使循环并行的代码。

解决方案

您的代码确实同时运行*，但不一定以非常优化的方式运行。您基本上已将工作负载一分为二，并且同时运行两半。

这不是真的，但我不知道你的教授说的具体内容，所以他可能没有对你撒谎。他显然想到了某种递归解决方案。我不会在这里使用递归，但这是一种方法。

很难提供您的教授正在寻找的答案。最好的建议是请你的教授解释他的意图。

*并发不是并行。请阅读/观看。

终于介绍完啦！小伙伴们，这篇关于《以下实现是否使我的代码并行？》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~米云公众号也会发布Golang相关知识，快来关注吧！