登录
首页 >  Golang >  Go问答

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

来源:stackoverflow

时间:2024-04-26 09:09:35 327浏览 收藏

知识点掌握了,还需要不断练习才能熟练运用。下面golang学习网给大家带来一个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 例程才能使循环并行的代码。


解决方案


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

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

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

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

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

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>