用于数据计算的Clojure core.async

Question

(def x-ch (chan))
(def y-ch (chan))
(def w1-ch (chan))
(def w2-ch (chan))

; they all return matrices
(go (>! x-ch (Mat/* x (map #(/ 1.0 %) (max-fold x)))))
(go (>! y-ch (Mat/* y (map #(/ 1.0 %) (max-fold y)))))
(go (>! w1-ch (gen-matrix 200 300)))
(go (>! w2-ch (gen-matrix 300 100)))

(let [x1 (<!! (go (<! x-ch)))
        y1 (<!! (go (<! y-ch)))
        w1 (<!! (go (<! w1-ch)))
        w2 (<!! (go (<! w2-ch)))]

    ;; do stuff w/ x1 y1 w1 w2
)

我在符号X和Y中有预定义的（矩阵）向量。在使用这两个向量之前，我需要修改它们。那些矢量很大。我还需要生成两个随机矩阵。由于go宏以异步方式启动计算，所以我将所有四个计算任务拆分为单独的go块，并将结果放到通道中。然后我得到了一个let块，在这里我从通道中获取值，并将它们存储到符号中。它们都在使用阻塞<！！take函数，因为它们位于主线程上。

我试图做的基本上是通过将程序片段拆分为异步进程来加快计算时间。这样做对吗？

Answer 1

对于这种处理，未来可能会稍微充分一些。

链接中的例子很容易理解：

 (def f 
   (future 
     (Thread/sleep 10000) 
     (println "done") 
     100))

的处理，未来的块是立即开始，所以上面做启动一个线程，等待10s和打印“完成”时完成。

(deref f)
; or @f

 (future 
    (Mat/* x (map #(/ 1.0 %) (max-fold x))))