如何确定从渠道接收的顺序？

哈喽！大家好，很高兴又见面了，我是golang学习网的一名作者，今天由我给大家带来一篇《如何确定从渠道接收的顺序？》，本文主要会讲到等等知识点，希望大家一起学习进步，也欢迎大家关注、点赞、收藏、转发! 下面就一起来看看吧！

考虑以下 go 之旅中的示例。

如何确定频道的接收顺序？ 为什么 x 总是从 gorouting 获得第一个输出？ 听起来很合理，但我没有找到任何有关它的文档。 我尝试添加一些睡眠，但仍然从第一次执行的 gorouting 中获取输入。

c := make(chan int)
    go sumSleep(s[:len(s)/2], c)
    go sum(s[len(s)/2:], c)
    x, y := <-c, <-c // receive from c

    fmt.Println(x, y, x+y)

睡眠是在发送到通道之前进行的。

解决方案

对 Adrian's answer 添加一点：我们不知道这两个 goroutine 可能以什么顺序运行。如果您的睡眠发生在通道发送之前，并且睡眠“足够长”，¹ 将保证其他 goroutine 可以运行到执行发送操作。如果两个 goroutine“同时”运行并且都不等待（如原始 tour 示例中所示），我们无法确定哪一个将首先到达其 c <- sum 行。

在 go 演示上运行 tour 的示例（直接或通过 tour 网站），我实际上得到：

-5 17 12

在输出窗口中，（因为我们知道 -9 位于切片的第二半）告诉我们第二个 goroutine“到达那里”（到通道发送） 第一的。从某种意义上说，这只是运气——但在使用 go 演示时，所有作业都在相当确定的环境中运行，使用单个 cpu 并进行协作调度，因此结果更可预测。换句话说，如果第二个 goroutine 在一次运行中首先到达那里，那么它可能会在下一次运行中到达那里。如果演示使用多个 cpu 和/或不确定性较低的环境，一次运行的结果可能会改变到下一次运行，但不能保证这一点。

无论如何，假设您的代码按照您所说的操作（并且我相信它确实如此），则：

go sumsleep(s[:len(s)/2], c)
go sum(s[len(s)/2:], c)

让第一个发送者等待，第二个发送者先运行。但这就是我们在让两个例程竞争时实际观察到的情况。要查看更改，我们需要延迟第二个发送者。

我对 go 演示 here 中的示例进行了修改，可以打印更多注释。在第二半和中插入延迟后，我们将前半和视为 x：

2nd half: sleeping for 1s
1st half: sleeping for 0s
1st half: sending 17
2nd half: sending -5
17 -5 12

正如我们所期望的，因为一秒“足够长”。

¹多长“足够长”？好吧，这取决于：我们的计算机有多快？他们还做了多少其他事情？如果计算机足够快，几毫秒甚至几纳秒的延迟可能就足够了。如果我们的计算机非常旧，或者非常忙于其他更高优先级的任务，那么几毫秒的时间可能不够。如果问题足够大，一秒钟可能不够。如果您可以通过某种同步操作更好地控制它，那么选择某个特定的时间量通常是不明智的，而且通常可以。例如，使用 sync.waitgroup 变量允许您等待 n 个 goroutine（对于 n 的某些运行时值）在您自己的 goroutine 继续之前调用 done 函数。

演示代码，为方便起见，复制到 stackoverflow

package main

import (
    "fmt"
    "time"
)

func sum(s []int, c chan int, printme string, delay time.Duration) {
    sum := 0
    for _, v := range s {
        sum += v
    }
    fmt.Printf("%s: sleeping for %v\n", printme, delay)
    time.Sleep(delay)
    fmt.Printf("%s: sending %d\n", printme, sum)
    c <- sum
}

func main() {
    s := []int{7, 2, 8, -9, 4, 0}

    c := make(chan int)
    go sum(s[:len(s)/2], c, "1st half", 0*time.Second)
    go sum(s[len(s)/2:], c, "2nd half", 1*time.Second)
    x, y := <-c, <-c

    fmt.Println(x, y, x+y)
}

消息总是按照发送的顺序接收。这是确定性的。

但是，并发 goroutine 之间任何给定操作的执行顺序不是确定的。因此，如果你有两个 goroutine 同时在一个通道上发送，你无法知道哪个将首先发送，哪个将第二个发送。如果你有两个 goroutine 在同一个通道上接收数据，情况也是如此。

本篇关于《如何确定从渠道接收的顺序？》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！