我和core.async一起玩,发现和它一起工作很有趣。然而,我无法理解用于mult和广播的不同用例是什么。两者都需要吗?还是会被另一个取代?到目前为止,我发现的唯一不同之处是,使用mult更容易进入和卸载。不知道如何取消订阅广播,这是唯一的区别吗?
下面是一个示例,演示如何使用这两种方法解决问题。
;; Using mult with tap
(def in (chan))
(def multiple (mult in))
(def out-1 (chan))
(tap multiple out-1)
(def out-2 (chan))
(tap multiple out-2)
(go (>! in "PutIN"))
(go (prn "From out-1: " (<! out-1)))
(go (prn "From out-2: " (<! out-2)))//
;; Using broadcast
(def bout-1 (chan))
(def bout-2 (chan))
(def broadcast-in (broadcast bout-1 bout-2))
(go (>! broadcast-in "PutINBroadcast"))
(go (prn "From bout-1: " (<! bout-1)))
(go (prn "From bout-2: " (<! bout-2)))发布于 2015-04-12 11:13:25
这是带有clojure.core.async.lab名称空间的broadcast的注释。
core.async高实验特征探索 注意事项:
有很长一段时间没有人使用它了,它从未移植到ClojureScript。我预计它将在不久的将来从core.async中删除。mult是后来的发展方向。
https://stackoverflow.com/questions/29579931
复制相似问题