处理超时和监听频道
处理超时和监听频道
提问于 2020-09-19 06:05:26
我的代码看起来像这样，我一直在监听一个频道，直到一个超时间隔。让我们假设这个goroutine 1
select {
case <-time.After(TimeoutInterval):
mu.Lock()
defer mu.Unlock()
delete(msgChMap, index)
return ""
case msg := <-msgCh:
return msg
}在其他地方，我有一个goroutine 2，它运行类似这样的东西，它从映射中获取适当的msgCh，删除映射中的条目，然后通过通道发送消息。
mu.Lock()
msgCh, ok := msgChMap[index]
delete(msgChMap, index)
mu.Unlock()
if ok {
msgCh <- "yay"
}似乎可以从映射中获取消息通道msgCh，尝试发送一条消息，但是因为TimeoutInterval已经传递，所以将不会有任何东西监听该通道，并且我的代码将在等待侦听器时被卡住。如果我在将yay发送到msgCh之后设置锁，似乎我可能会死锁，因为2将等待通道的侦听器，而不是释放锁，但是1不再侦听，而是需要锁。
为了避免等待听众而陷入困境的一般模式是什么？也许go足够聪明，不会被困在这里。
Stack Overflow用户
发布于 2020-09-19 06:23:20
这里的问题是，通道阅读器会在编写器不知道的情况下停止。应该可以构造这个解决方案，使这种情况永远不会发生，但是现在忽略这一点，对于这个特定的问题，您需要的是对通道本身的原子访问，以及通道状态的标志：
type channel struct {
sync.Mutex
msgCh chan Msg
active bool
}现在可以通过锁定通道来完成对通道的写入：
ch.Lock()
if ch.active {
ch.msgCh<-data
}
ch.Unlock()当你“停用”该通道时，重置该标志：
case <-time.After(TimeoutInterval):
mu.Lock()
defer mu.Unlock()
ch.Lock()
defer ch.Unlock()
delete(msgChMap, index)
ch.active=false
return ""当然，现在您必须在地图中保留一个*channel。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/63963366
复制相关文章
相似问题
腾讯云开发者
