管理超时和监控通道

小伙伴们对Golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《管理超时和监控通道》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

我的代码如下所示，我正在监听一个频道，直到超时间隔。假设这个 goroutine 1

select {
    case <-time.after(timeoutinterval):
        mu.lock()
        defer mu.unlock()
        delete(msgchmap, index)
        return ""
    case msg := <-msgch:
        return msg
}

在其他地方，我有一个 goroutine 2 ，它运行类似的东西，它从 map 中获取适当的 msgch ，删除映射中的条目，然后通过通道发送消息。

mu.Lock()
msgCh, ok := msgChMap[index]
delete(msgChMap, index)
mu.Unlock()
if ok {
    msgCh <- "yay"
}

看来我可以从地图上抓取消息通道msgch，尝试发送消息，但是因为timeoutinterval已经过去了，所以不会有任何东西在监听该通道，并且我的代码将卡在等待一个倾听者。如果我在将 yay 发送到 msgch 后放置锁，则似乎可能会死锁，因为 2 将等待通道的侦听器并且不会释放锁，但 1 不再侦听但需要锁。 p>

避免陷入等待侦听器的一般模式是什么？也许 go 足够聪明，不会被困在这里。

解决方案

通过使用 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
    }
}

这里的问题是频道阅读器在作者不知情的情况下停止了。应该可以构建这个解决方案，以便这种情况永远不会发生，但现在忽略这一点，对于这个特定问题，您需要的是对通道本身的原子访问，以及通道状态的标志：

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。

以上就是《管理超时和监控通道》的详细内容，更多关于的资料请关注golang学习网公众号！