处理超时和监听频道
处理超时和监听频道
提问于 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足够聪明，不会被困在这里。
回答 2
Stack Overflow用户
回答已采纳
发布于 2020-09-19 14:53:02
通过对发送方使用select，可以防止在等待监听器时卡住。
在这种情况下，通过使用select，您可以对发件人使用更多的case
mu.Lock()
msgCh, ok := msgChMap[index]
delete(msgChMap, index)
mu.Unlock()
if ok {
select {
// listener is available
case msgCh <- "yay":
fmt.Println("sent")
// if not avalable (execute immediately)
default:
fmt.Println("no available listener")
// ...just ignore or do something else
}
}或等待一小段时间
mu.Lock()
msgCh, ok := msgChMap[index]
delete(msgChMap, index)
mu.Unlock()
if ok {
select {
// listener is available
case msgCh <- "yay":
fmt.Println("sent")
// if not available, waiting for listener
case <-time.After(30 * time.Second):
fmt.Println("after 30 seconds, still no available listener")
// ...just ignore or do something else
}
}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
复制相关文章
相似问题
腾讯云开发者
