algorithm - 读取和写入同一 channel 的工作池去

Question

我需要你的帮助。目前，我正在尝试创建一个工作池，该工作池从一个 channel 读取连续的作业，然后将结果生成到它正在读取的同一 channel ，然后进行工作并将结果生成到同一 channel 。你的想法有点像递归。有什么办法可以使这成为可能吗？我真的很感激您关于设计模式的建议，以使用 go 例程作为工作池和 channel 来实现此解决方案以读取作业，然后从同一工作池将该作业的结果写入同一 channel 以继续工作。谢谢你。

Answer 1

没有理由不能(从 Go 的角度)在读取后写回 channel :

func Foo(c chan int) {
  x := <-c
  // do something to x
  c <- x
}

虽然这很奇怪……老实说不推荐它。通常我见过一个由几个 channel 组成的系统，数据向下传递，不进入循环。想想树而不是图。