理解和学习并发合并排序

在并发环境中，合并排序算法通过并发合并多个已排序子序列来提升效率。该算法利用通道进行通信，将待排序序列划分为两部分，并分别在 goroutine 中进行合并排序。当子序列排序完成后，主 goroutine 从通道中读取并比较子序列的第一个元素，将较小的元素写入输出通道，并更新子序列的第一个元素。此过程持续进行，直到所有子序列都合并完成，形成最终的已排序序列。

在并发方面我还是个初学者，我正在研究 go 中的并发合并排序。

我看到另一个关于有人试图实现同样的事情的问题。答案包含 for ok1 || 的代码ok2 在合并函数的底部。我不明白发生了什么，谁能详细解释一下合并功能？

谢谢。代码如下。

package main

import (
    "fmt"
    "math/rand"
    "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

    for ok1 || ok2 {
        if (ok1 && ok2 && v1 < v2) || (ok1 && !ok2) {
            fmt.Printf("v1 = %v, ch = %v", v1, ch)
            ch <- v1
            v1, ok1 = <-ch1
        } else if (ok1 && ok2 && v1 >= v2) || (!ok1 && ok2) {
            ch <- v2
            v2, ok2 = <-ch2
            fmt.Printf("v2 = %v, ch = %v", v2, ch)
        }
    }
    close(ch)
}

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

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

func generateSlice(size int) []int {

    slice := make([]int, size)
    rand.Seed(time.Now().UnixNano())
    for i := 0; i < size; i++ {
        slice[i] = rand.Intn(999) - rand.Intn(999)
    }
    return slice
}

func main() {
    slice := generateSlice(10)
    start := time.Now()
    sorted := Merge(slice)
    fmt.Printf("Time taken to sort: %v, sorted: %v", time.Since(start), sorted)
}

正确答案

ok1 和 ok2 是一对通道读取的第二个返回，如果正在读取的通道为空且关闭（没有更多值，也没有更多值），则为 false。在这种情况下，读取的值将是通道类型的零值，因此不应将其视为“真实”值。只要其中一个为真，仍然有值需要处理，这就是它用于循环的原因。

https://go.dev/tour/concurrency/4

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