避免 goroutine 之间的死锁问题

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《避免 goroutine 之间的死锁问题》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

我正在第一次体验 go，到目前为止，我真的很喜欢 goroutine 和通道结构。我想知道是否有一种惯用的方法可以避免多个 goroutine 之间的双向通信出现死锁。考虑以下示例。共有三个 goroutine：生产者、工作人员和控制器。

• 生产者生产整数。实际上这可能是数据到来 例如，通过网络连接。

• worker从生产者那里接收数据并进行一些操作 它。然后，worker 将修改后的数据发送给控制器。

• 在某些情况下，控制器会向工作线程发送命令。在里面 例如，如果接收到的整数大于 180，就会发生这种情况。

当控制器尝试向工作线程发送命令，而工作线程尝试向控制器发送整数时，就会发生死锁。

producertoworker := make(chan int)
workertocontroller := make(chan int)
controllertoworker := make(chan bool) // bool represents a command for this example

// worker
go func() {
    for {
        select {
        case i := <-producertoworker:
            // do some processing and send to controller
            workertocontroller <- (2 * i) + 1
        case <-controllertoworker:
            // would react to the command here
        }
    }
}()

// controller
go func() {
    for {
        select {
        case i := <-workertocontroller:
            fmt.println(i)
            if i > 180 {
                // send a command to the worker
                controllertoworker <- true
            }
        }
    }
}()

// producer
for {
    producertoworker <- rand.intn(100)
}

示例输出：

163
175
95
113
1
189 // No deadlock
23
125
179
57
149
23
91
191 // No deadlock
133
95
175
177
181 // No deadlock
17
175
63
27
181 // Deadlock!
fatal error: all goroutines are asleep - deadlock!

对通道进行缓冲可以使这种死锁的可能性降低，但不能从逻辑上解决它。如果可能的话，我想避免互斥体。在 go 中你如何处理这种情况？

编辑：为了给出更真实的描述：当我尝试实现 websocket 客户端时，我遇到了这个问题。 websocket 客户端 (worker) 连接到外部服务 (生产者) 并从其接收消息 ( producertoworker) 并将它们传递给控制器​​ (生产者) workertocontroller）来处理接收到的消息。控制器需要对收到的消息做出反应，例如在收到无效消息时发送响应或断开客户端连接 (controllertoworker)。

解决方案

没有。没有什么“惯用的”或基于“模式”的内容。

你重新设计。最好避免并发循环数据流。

到这里，我们也就讲完了《避免 goroutine 之间的死锁问题》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！