gpt4 book ai didi

go - 我靠运气解决的Golang僵局,需要说明

转载 作者:行者123 更新时间:2023-12-01 21:15:07 25 4
gpt4 key购买 nike

我正在尝试了解 channel 和例程。为此,我正在进行在线练习。我在这里找到一个:http://whipperstacker.com/2015/10/05/3-trivial-concurrency-exercises-for-the-confused-newbie-gopher/

我解决了第三个问题(名为“网吧”)。
但是我通过“运气”解决了某些问题,这困扰着我,因为我不了解我的问题以及为什么我的“hack”解决了这个问题。

在下面的代码中,我将“enterChan <-next”替换为“go func(){enterChan <-next}()”,它解决了我的僵局。

有人可以向我解释为什么它之前会死锁,以及为什么它可以与这种hack一起使用吗?这是一个适当的解决方案,还是一个丑陋的解决方案?

不要犹豫,批评我的代码,我正在寻求改进:)

非常感谢!

这是我的代码:

package main

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

const (
maxNumberOfUser = 8
)

func useComputer(tourist string, leaverChan chan string) {
seed := rand.NewSource(time.Now().UnixNano())
random := rand.New(seed)
fmt.Println(tourist, "is online")
d := random.Intn(120-15) + 15
time.Sleep(time.Duration(d) * time.Millisecond * 10)
fmt.Println(tourist, "is done, having spent", d, "minutes online.")
leaverChan <- tourist
}

func manageUsers(enterChan, leaverChan chan string, stopChan chan struct{}) {
nbUsed := 0
queue := make([]string, 0)
for {
select {
case tourist := <-enterChan:
if nbUsed < maxNumberOfUser {
nbUsed++
go useComputer(tourist, leaverChan)
} else {
fmt.Println(tourist, "waiting for turn.")
queue = append(queue, tourist)
}
case tourist := <-leaverChan:
nbUsed--
fmt.Println(tourist, "is leaving, number of free place is now:", maxNumberOfUser-nbUsed)
if len(queue) > 0 {
next := queue[0]
queue = queue[1:]
go func() {
enterChan <- next
}()
} else if nbUsed == 0 {
close(stopChan)
return
}

}
}
}

func main() {
enterChan := make(chan string)
leaverChan := make(chan string)
stopChan := make(chan struct{})
go manageUsers(enterChan, leaverChan, stopChan)

for i := 1; i <= 25; i++ {
enterChan <- "Tourist " + strconv.Itoa(i)
}
<-stopChan
fmt.Println("The place is empty, let's close up and go to the beach!")
}

最佳答案

如@ dev.bmax所解释, enterChan 不是缓冲的 channel ,您正尝试将数据发送到未被读取的 channel 。例如,下面的代码将导致死锁错误:

package main
import (
"fmt"
)


func main() {
stream := make(chan int)
<-stream
stream<-1

fmt.Println("Yayyy!! no deadlock!")
}

您可以运行上面的代码 here并检查它是否有死锁。但是,如果我将其更改为:
package main
import (
"fmt"
)


func main() {
stream := make(chan int)
go func(){<-stream}()
stream<-1
fmt.Println("Yayyy!! no deadlock!")
}

我们没有僵局。因为我们启动了另一个从 channel 读取的GoRoutine,而主GoRoutine正在将数据推送到 channel 。希望这可以帮助!

关于go - 我靠运气解决的Golang僵局,需要说明,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45683375/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com