如何尽可能晚地计算要在通道上发送的消息？

Question

我的场景：

• 我有一个生产者和一个消费者。两者都是 goroutine，它们通过一个通道进行通信。
• 生产者能够（理论上）随时生成消息。
• 生成消息需要一些计算。
• 消息在一定程度上具有时间敏感性（即，消息越旧，相关性越低）。
• 消费者偶尔会从频道读取数据。在本示例中，假设消费者使用 time.Ticker 每隔几秒读取一次消息。
• 消费者更喜欢“新鲜”的消息（即尽可能最近生成的消息）。

所以，问题是：生产者如何尽可能晚地生成消息？

---

显示总体思路的示例代码：

func producer() {
    for {
        select {
        ...
        case pipe <- generateMsg():
            // I'd like to call generateMsg as late as possible,
            // i.e. calculate the timestamp when I know
            // that writing to the channel will not block.
        }
    }
}

func consumer() {
    for {
        select {
        ...
        case <-timeTicker.C:
            // Reading from the consumer.
            msg <- pipe
            ...
        }
    }
}

完整代码（与上面略有不同）可在 Go Playground 获得：https://play.golang.org/p/y0oCf39AV6P

---

我的一个想法是检查写入频道是否会阻塞。如果它不会阻塞，那么我可以生成一条消息然后发送它。不过……

• 我找不到任何方法来测试写入通道是否会阻塞。
• 在一般情况下，这是一个坏主意，因为如果我们有多个生产者，它会引入竞争条件。在这种特定情况下，我只有一个制作人。

---

另一个（坏）主意：

func producer() {
    var msg Message
    for {
        // This is BAD. DON'T DO THIS!
        select {
        case pipe <- msg:
            // It may send the same message multiple times.
        default:
            msg = generateMsg()
            // It causes a busy-wait loop, high CPU usage
            // because it re-generates the message all the time.
        }
    }
}

Answer 1

This answer（代表Go non-blocking channel send, test-for-failure before attempting to send?）建议使用第二个通道将信号从消费者发送到生产者：

1. 消费者想要收到一条消息（例如，在收到来自timer.Ticker 的勾选后）。
2. 消费者通过侧通道向生产者 goroutine 发送信号。 （因此，对于这个侧通道，生产者/消费者角色是相反的）。
3. 生产者接收来自侧通道的信号。
4. 生产者开始计算真正的消息。
5. 生产者通过主渠道发送消息。
6. 消费者收到消息。