登录
首页 >  Golang >  Go问答

如何修复Go中的并发合并排序

来源:stackoverflow

时间:2024-04-19 16:24:38 220浏览 收藏

学习知识要善于思考,思考,再思考!今天golang学习网小编就给大家带来《如何修复Go中的并发合并排序》,以下内容主要包含等知识点,如果你正在学习或准备学习Golang,就都不要错过本文啦~让我们一起来看看吧,能帮助到你就更好了!

问题内容

我正在尝试学习 go lang,并面临同时实现合并排序的问题。它没有正确对数组进行排序

我尝试过寻找任何竞争条件,并尝试在各个阶段进行打印。但似乎无法弄清楚这个问题。有什么工具可以分析和指出此类问题。

package main

import (
    "fmt"
    "time"
)

func merge(a []int, ch chan int) {
    //     defer close(ch)
    if len(a) == 0 {
        close(ch)
        return
    }

    if len(a) == 1 {
        ch <- a[0]
        close(ch)
        return
    }

    mid := len(a) / 2

    ch1 := make(chan int)
    go merge(a[:mid], ch1)

    ch2 := make(chan int)
    go merge(a[mid:], ch2)

    v1, ok1 := <-ch1
    v2, ok2 := <-ch2
    var t []int
    for ok1 == true && ok2 == true {
        if v1 < v2 {
            ch <- v1
            t = append(t, v1)
            v1, ok1 = <-ch1
        } else {
            ch <- v2
            t = append(t, v2)
            v2, ok2 = <-ch2
        }
    }
    close(ch)
}

func Merge(a []int) (sortedA []int) {
    ch := make(chan int)
    go merge(a, ch)

    for v := range ch {
        sortedA = append(sortedA, v)
    }
    return
}

func main() {
    arr := []int{3, 34, 23, 65, 34, 7, -1, 0, -23}
    start := time.Now()
    b := Merge(arr)
    fmt.Printf("Time taken to sort: %v, sorted: %v", time.Since(start), b)
}

我预计输出为 [-23 -1 0 3 7 23 34 34 65] 但实际输出仅为 -23


解决方案


您的合并阶段已损坏:您必须在 ch 上发送 ch1ch2 的所有值,但一旦 ch1ch2 的任何被耗尽,您的代码就会停止。一旦你排空,例如ch2 您必须将 ch1 中的所有内容发送到 c

一些事情(确保清理条件!)

for ok1 || ok2 {
    if (ok1 && ok2 && v1 < v2) || (ok1 && !ok2) {
        ch <- v1
        v1, ok1 = <-ch1
    } else if (ok1 && ok2 && v1 >= v2) || (!ok1 && ok2) {
        ch <- v2
        v2, ok2 = <-ch2
    }
}

终于介绍完啦!小伙伴们,这篇关于《如何修复Go中的并发合并排序》的介绍应该让你收获多多了吧!欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识,快来关注吧!

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