go - 处理超时并收听 channel

Question

我有看起来像这样的代码，在这里我一直在监听 channel 直到超时间隔。假设这个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，删除 map 中的条目，然后通过 channel 发送消息。

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

似乎我可以从 map 中获取消息 channel msgCh，尝试发送消息，但是由于 TimeoutInterval已经通过，因此无法监听该 channel ，并且我的代码将陷入等待监听器的状态。如果我在将 yay发送到 msgCh之后放了锁，则似乎我可能会死锁，因为 2将等待 channel 的监听器并且不会释放该锁，但是 1不再监听而是需要该锁。
有什么通用模式可以避免等待听众时陷入困境？也许go足够聪明，不会被困在这里。

Answer 1

您可以通过将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
    }
}