我怎样才能避免死锁

Question

看下面的代码片段。package mainimport (    "errors"    "fmt"    "math/rand"    "runtime"    "sync"    "time")func random(min, max int) int {    rand.Seed(time.Now().Unix())    return rand.Intn(max-min) + min}func err1(rand int, chErr chan error, wg *sync.WaitGroup) {    if rand == 1 {        chErr <- errors.New("Error 1")    }    wg.Done()}func err2(rand int, chErr chan error, wg *sync.WaitGroup) {    if rand == 2 {        chErr <- errors.New("Error 2")    }    wg.Done()}func err3(rand int, chErr chan error, wg *sync.WaitGroup) {    if rand == 3 {        chErr <- errors.New("Error 3")    }    wg.Done()}func err4(rand int, chErr chan error, wg *sync.WaitGroup) {    if rand == 3 {        chErr <- errors.New("Error 4")    }    wg.Done()}func err5(rand int, chErr chan error, wg *sync.WaitGroup) {    if rand == 4 {        chErr <- errors.New("Error 5")    }    wg.Done()}func main() {    runtime.GOMAXPROCS(runtime.NumCPU())    chErr := make(chan error, 1)    wg := new(sync.WaitGroup)    //n := random(1, 8)    n := 3    fmt.Println(n)    wg.Add(5)    go err1(n, chErr, wg)    go err2(n, chErr, wg)    go err3(n, chErr, wg)    go err4(n, chErr, wg)    go err5(n, chErr, wg)    fmt.Println("Wait")    wg.Wait()    select {    case err := <-chErr:        fmt.Println(err)        close(chErr)    default:        fmt.Println("NO error, job done")    }}我怎样才能避免这里的僵局？我可以指定缓冲区长度为 2，但也许它有更优雅的方法来解决问题。我有意识地在函数 err3 和 err4 上做了 rand == 3 。

Answer 1

通常，不要陷入认为更大的缓冲区可以修复死锁的陷阱。这种方法可能在某些特定情况下有效，但通常并非如此。

死锁最好通过了解 goroutine 如何相互依赖来解决。本质上，您必须消除相互依赖的通信循环。非阻塞发送的想法（参见@izca 的回答）是一种有用的技巧，但不是唯一的技巧。

有大量关于如何避免死锁/活锁的知识。其中大部分来自奥卡姆在 80 年代和 90 年代流行的日子。有一些来自诸如 Jeremy Martin（无死锁并发系统的设计策略）、Peter Welch（高级范式）等人的特别珍宝。

1. 客户端-服务器策略很简单：将您的 Go 例程网络描述为一组通信服务器及其客户端；确保网络图中没有循环 => 消除了死锁。

2. I/o-par 是一种形成 Go-routines 的环和环的方法，这样结构内就不会出现死锁；这就是循环特定情况下是允许的，但行为方式一般无死锁的方式。

所以，我的策略是首先减少缓冲区大小，考虑发生了什么，修复死锁。然后，根据基准重新引入缓冲区以提高性能。死锁是由通信图中的循环引起的。打破循环。

Answer 2

您的节目陷入僵局，因为您的频道已满。

您的频道大小为 1。然后调用wg.Wait().. 等待调用5 个函数。现在，一旦您到达err3.. rand == 3，因此您的频道会传递错误。

此时，您的频道已满，您只勾选了 3 个等待组项目。

err4使用值 3 .. 调用它也想在您的频道上放置错误。此时，它会阻止 - 因为您的频道已满并且没有从中弹出任何内容。

所以你的主要 goroutine 会阻塞，因为你的等待组永远不会完成。

修复确实是使您的通道缓冲区更大。这样，当错误试图放置在通道上时 - 它不会阻塞，并且您的等待组有机会勾选它的所有项目。