如何用尽一个通道的值，然后返回结果（ClojureScript）？

Question

假设通道chan在队列上具有值“1”和“2”。

目标：创建一个函数，它接受chan并返回向量[1 2]。请注意，如果这个函数在返回它的值之前必须阻塞一段时间，我是完全没有问题的。

(defn chan->vector
  [chan]  
  (let [a (atom true) v []]
    (while (not-nil? @a)
      (go
        (reset! a (<! chan))
        (into v @a)
        (reset! a (<! chan))
      )
    ) v
  )
)

Answer 1

您应该使用core.async中的alts！来完成此任务(https://clojure.github.io/core.async/#clojure.core.async/alts！）：

(def x (chan 10))

(go (>! x 1)
    (>! x 2)
    (>! x 3))

(defn read-all [from-chan]
  (<!! (go-loop [res []]
           (let [[v _] (alts! [from-chan] :default :complete)]
             (if (= v :complete)
               res
               (recur (conj res v)))))))

(read-all x) 
;; output: [1 2 3]

(read-all x)
;; output: []

(go (>! x 10)
    (>! x 20)
    (>! x 30)
    (>! x 40))

(read-all x)
;; output: [10 20 30 40]

在go-loop内部，这个(A/alts！[from-chan]:default:complete)尝试从通道读取任何值，如果没有可用的值，它会发出默认值，因此您将看到应该中断循环并返回累加值。

更新：由于CLJ中没有阻塞读取(<！！)，您可以用以下方法重写它：

(defn read-all [from-chan]
  (go-loop [res []]
    (let [[v _] (alts! [from-chan] :default :complete)]
      (if (= v :complete)
        res
        (recur (conj res v)))))))

所以它会返回通道，然后从那里读取一个值：

(go (let [res (<! (read-all x))]
      (println res)
      ;; do something else
      ))