Golang 中如何通过调整通道接收顺序来避免死锁问题？

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《Golang 中如何通过调整通道接收顺序来避免死锁问题？》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

我已将问题归结为下面这个简单的示例。我正在调用一个 goroutine，它采用两个通道并向每个通道发送一条消息。然后我尝试进一步接收这些消息。然而，渠道接收的顺序很重要。如果我使用发送消息的相同顺序，程序就会运行。如果我切换，则不会。

我希望 goroutine 能够独立于检索消息而运行，从而允许我从我想要首先接收的任何通道接收消息。

我可以通过向每个 goroutine（2 个 goroutine）的单个通道发送消息来解决这个问题。

有人可以解释为什么这里存在顺序依赖以及为什么两个单独的 goroutine 解决了这种依赖吗？

package main

import "fmt"

func main() {
    chanA := make(chan string)
    chanB := make(chan string)

    go func() {
        chanA <- "el"
        chanB <- "el"
    }()

    // if B is received before A, fatal error
    // if A is received before B, completes
    <-chanB
    <-chanA

    fmt.Println("complete")
}

正确答案

您需要缓冲您的频道。缓冲通道在阻塞之前可以存储如此多的元素。

chana := make(chan string, 1)
chana <- "el" // this will not block
fmt.println("hello world")

当您在上面的缓冲通道上执行 chana <- "el" 时，元素将被放置到缓冲区中，并且线程不会阻塞。如果添加第二个元素，它将被阻塞，因为缓冲区中没有空间：

chana := make(chan string, 1)
chana <- "el"
chana <- "el" // <- this will block, as the buffer is full

在您的示例中，缓冲区为 0。因此对通道的第一次写入被阻止，并且需要另一个线程读取该值才能解除阻止。

https://go.dev/play/p/6GbsVW4d0Mg

chana := make(chan string)
    go func() {
        time.sleep(time.second)
        fmt.println("pop:", <-chana) // unblock the writer
    }()
    chana <- "el"

额外知识

如果您不希望线程阻塞，您可以将通道插入包装在选择中。这将确保如果通道已满，您的应用程序不会死锁。解决这个问题的一种廉价方法是使用更大的缓冲区......

https://go.dev/play/p/kKR-lrCO4FX

select {
    case chanA <- "el":
    default:
        return fmt.Errorf("value not written: %s", value)
    }

这就是 goroutine 的工作原理：

请注意上述屏蔽引用中的读/写和写/读。

在你的情况下，你的匿名goroutine（你用go启动）等待在channela上写入，直到找到一个从channela读取的goroutine。 主 goroutine 等待从 channelb 读取数据，除非它找到一个从 channelb 读取数据的 goroutine。

你可以这样想，读/写通道后写入的任何行都不会被考虑，除非 go 找到另一个从同一通道写/读的例程。

因此，如果您更改读取或写入顺序，您将不会出现死锁，或者正如您所说，另一个 goroutine 也可以完成这项工作。

希望一切都清楚。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~