竞赛模拟致命错误：所有 goroutine 都在休眠 - 死锁

大家好，今天本人给大家带来文章《竞赛模拟致命错误：所有 goroutine 都在休眠 - 死锁》，文中内容主要涉及到，如果你对Golang方面的知识点感兴趣，那就请各位朋友继续看下去吧~希望能真正帮到你们，谢谢！

我正在 golang 中构建护理模拟，但遇到了僵局问题。 goroutines 用于代表每个赛车手。 这个想法是，一旦赛车手达到目标，就会使用一个通道来传达哪位赛车手获胜。 谁能发现我的错误吗？

package main

import (
    "fmt"
    "math/rand"
    "strconv"
    "sync"
    "time"
)

var wg sync.WaitGroup
var counter Counter
var tracks Tracks
var winner chan int

func newCounter(size int) Counter {
    return Counter{racers: make([]int, size+1)} // not using the zero'th index
}

func newTracks(size int) Tracks {
    return Tracks{racers: make([]string, size+1)}
}

func incrementCounter(n int) {
    counter.racers[n]++
}

func equalCounter() bool {
    rv := true
    for i, _ := range counter.racers {
        if counter.racers[0] != counter.racers[i] {
            rv = false
            break
        }
    }
    return rv
}

func smallerCounter(racerNumber int) bool {
    var rv bool
    for v := range counter.racers {
        if counter.racers[racerNumber] < v {
            rv = true
        } else {
            rv = false
        }
    }

    return rv
}

func checkCounter(racerNumber int) bool {
    var rv bool
    if equalCounter() || smallerCounter(racerNumber) {
        rv = true
    } else {
        rv = false
    }

    return rv
}

func racer(racerNum int) {
    steps := rand.Intn(5) + 1
    distance := 0
    goal := 100
    if checkCounter(racerNum) {
        for j := distance; distance < goal; j++ {
            for i := 0; i < steps; i++ {
                tracks.racers[racerNum] += "x"
            }
            distance += steps
            duration := rand.Int31n(200)
            time.Sleep(time.Duration(duration) * time.Millisecond)
            fmt.Println(tracks.racers[racerNum] + "[" + strconv.Itoa(racerNum) + "]")
        }

        incrementCounter(racerNum)
    }

    if distance >= goal {
        winner <- racerNum
        close(winner)
    }

    wg.Done()
}

func main() {
    racers := 5
    counter = newCounter(racers)
    tracks = newTracks(racers)

    for i := 1; i <= racers; i++ {
        wg.Add(1)
        go racer(i)
    }

    wg.Wait()

    fmt.Print("Winner is:")
    fmt.Print(<-winner)
}


type Counter struct {
    racers []int
}

type Tracks struct {
    racers []string
}

代码也在这里运行：

https://play.golang.org/p/skr5es3itfq

解决方案

死锁原因：

• 结果通道是无缓冲的，因此多个写入将被阻塞，因此 wg.done() 永远不会运行
• 在所有 5 个 wg.done() 运行之前，不会从结果通道中读取任何内容（先有鸡还是先有蛋的问题）

快速修复，使结果通道缓冲以及所有总写入的大小：

winner = make(chan int, racers)

https://play.golang.org/p/sbHfOr9YS_z

频道也会将所有亚军成绩放入频道队列中。

如果您只关心获胜者，那么有更有效的方法可以满足这种情况，例如创建一个 referee go-routine 来监视第一次写入（获胜者）到结果通道，然后取消比赛 context （每个赛车手监视上下文取消，一旦宣布单个获胜者，就会放弃他们的任务）

您的程序存在多个问题：

• 这很生动。当其他赛车手在没有任何锁定的情况下写入计数器时，您正在读取计数器。使用 sync.atomic 函数来读取/写入这些值，或者使用锁定
• if counter.racers[0] != counter.racers[i] { 程序中没有写入 counter.racers[0]，因此它始终为零。这意味着，在其中一个 goroutine 完成后，equalcounter 将始终返回 false
• smallercounter 始终返回最后一位赛车手的比较结果。这是一个重置同一变量的 for 循环，因此最后一个变量会幸存。
• 第一个获胜者关闭频道。如果在程序终止之前有其他 goroutine 写入它，这将导致恐慌。
• wg.wait 在通道读取之前，因此所有 goroutine 都被锁定等待写入。

终于介绍完啦！小伙伴们，这篇关于《竞赛模拟致命错误：所有 goroutine 都在休眠 - 死锁》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！