如何在没有隐式缓冲区的情况下将值从一个 Go 通道传输到另一个通道？

Question

假设我有一个从一个通道读取并写入另一个通道的 goroutine。

ch1 := make(chan int)
ch2 := make(chan int)
go func() {
  for num := range ch1 {
    ch2 <- num+1
  }
}()

如果 ch2 被阻塞，goroutine 仍然会从 ch1 读取一个值，有效地在通道中引入一个 1 的缓冲区。由于我使用通道进行控制流，因此我不需要任何缓冲。

如何制作一个以完全锁步方式执行的管道？ 或者换句话说，如何在一个原子操作中将值从一个通道传输到下一个通道？

我基本上想等待ch1 和ch2 到达集合点。

Answer 1

您不能使用 2 个频道来执行此操作。为了在ch2 上执行发送，要发送的值必须已经准备好、已评估。 Spec: Send statements:

通道和值表达式都在通信开始之前进行评估。

因此，即使您这样做，它似乎也不会缓冲任何变量中的值：

ch2 <- (<- ch1)

不过，来自ch1 的接收将首先被评估，然后才会尝试发送。

这意味着该值必须已经从ch1 收到。但是，如果不尝试在 ch2 上发送，您就无法判断是否有人在 ch2 上“收听”（这意味着是否可以继续在 ch2 上发送）（即使可以，也不能保证尝试检查后发送仍然会有人在听它）。