Clojure - core.async 合并单向通道

Question

我有两个单向core.async 频道：

• 频道输出只能put!
• 频道只能take!

因为这是 ClojureScript，所以阻塞操作不可用。我想从这两个（输入和输出）通道中创建一个双向（输入输出）通道。

  (def in (async/chan))
  (def out (async/chan))
  (def in-out (io-chan in out)) ;; io or whatever the solution is

  (async/put! in "test")
  (async/take! ch (fn [x] (println x))) ;; should print "test"
  (async/put! ch) ;; put into ch is equivalent to putting into `out`

我尝试了类似以下的方法（不起作用）：

(defn io-chan [in-ch out-ch]
  (let [io (chan)]
    (go-loop []
      (>! out-ch (<! io ))
      (>! io (<! in-ch))
      (recur))
    io))

架构可能会有所帮助：

    out                              in-out
 ---------------> (unused)         
 <---------------             <---------------

   in
---------------->             ---------------->
<---------------- (unused)

另外，关闭双向通道应该关闭两个底层通道。

有可能吗？

Answer 1

如果我正确理解您的用例，我相信您尝试做的只是单渠道工作。

另一方面，如果您尝试为多个通道的组合呈现一个类似于通道的接口（例如，某些进程从in 获取数据，对其进行处理，然后将结果输出到@ 987654323@），那么你总是可以实现正确的protocols（在ClojureScript的情况下，cljs.core.async.impl.protocols/ReadPort和cljs.core.async.impl.protocols/WritePort）。

我个人不推荐它。撇开您依赖实现细节这一事实不谈，我不认为 core.async 通道旨在作为流程的封装，而只是作为它们之间的通信点。所以在这个用例中，只需将输入通道传递给生产者，将输出通道传递给消费者。

Answer 2

您的示例显示的流程基本如下：

io ---> out-ch ---> worker ---> in-ch ---> io
^-------------------------------------------*

如果我们假设工作者从in-ch 读取并写入out-ch，那么在示例中这两个通道可能是相反的。如果工人反其道而行之，那就对了。为了防止循环，使用非缓冲队列很重要，这样您就不会听到自己的消息回响给自己。

附带说明，没有单向和双向通道之类的东西。取而代之的是缓冲和非缓冲通道。如果我们正在通过缓冲频道交谈，那么当我有话要对您说时，我会停下来，直到您碰巧正在收听该频道，然后一旦您准备好听到它，我就会将我的信息放入频道并且您会收到它。然后为了得到回复，我会一直等待，直到你准备好发送它，一旦你准备好，你把它放在频道上，我从频道里得到它（一次全部）。这感觉就像一个双向通道，尽管实际上只是无缓冲通道恰好以这种方式进行协调。

如果通道被缓冲，那么我可能会从通道中获取我自己的消息，因为我会完成将它放在通道上，然后准备好在你之前接收响应，甚至准备好接收原始消息。如果您需要像这样使用缓冲通道，请使用其中两个，每个方向一个，它们会“感觉”像单向通道。