6

我有两个独立的昂贵功能。我想并行运行它们。我不想处理期货等（我是 Clojure 的新手，很容易混淆）。

我正在寻找一种同时运行两个功能的简单方法。我希望它像下面这样工作

(defn fn1 [input] ...) ; costly
(defn fn2 [input] ...) ; costly

(let [[out1 out2] (conc (fn1 x) (fn2 y))] ...)

我希望它返回一个带有一对输出的向量。它应该只在两个线程都终止后才返回。理想情况下， conc 应该适用于任意数量的输入。我怀疑这是一个简单的模式。

4

3 回答 3

4

在 Clojure 中使用期货非常容易。无论如何，这是一个避免它们的答案

(defn conc [& fns]
  (doall (pmap (fn [f] (f)) fns)))

pmap在后台使用期货。doall将强制序列进行评估。

(let [[out1 out2] (conc fn1 fn2)]
        [out1 out2])

请注意，我解构out1并out2试图保留您的示例。

于 2012-09-13T22:48:03.900 回答
3

您确实需要一个宏来保留所需的语法，尽管还有其他方法可以获得相同的行为，正如其他答案所示。这是一种方法：

(defn f1 [x] (Thread/sleep 500) 5)
(defn f2 [y] 2)

(defmacro conc [& exprs]
  `(map deref
        [~@(for [x# exprs] `(future ~x#))]))

(time (let [[a b] (conc (f1 6) (f2 7))]
       [a b]))
; "Elapsed time: 500.951 msecs"
;= (5 2)

扩展显示了它是如何工作的：

(macroexpand-1 '(conc (f1 6) (f2 7)))
;= (clojure.core/map clojure.core/deref [(clojure.core/future (f1 6)) 
;=                                       (clojure.core/future (f2 7))])

您指定了两个函数，但这应该适用于任意数量的表达式。

于 2012-09-14T00:10:13.230 回答
2

我知道您不希望您的最终解决方案公开期货，尽管说明如何使用期货进行此操作很有用，然后将它们包装在隐藏此细节的东西中：

core> (defn fn1 [input] (java.lang.Thread/sleep 2000) (inc input))
#'core/fn1                                                                                     
core> (defn fn2 [input] (java.lang.Thread/sleep 3000) (* 2 input))
#'core/fn2                                                                                     
core> (time (let [f1 (future (fn1 4)) f2 (future (fn2 4))] @f1 @f2))
"Elapsed time: 3000.791021 msecs"

然后我们可以将它包装在围绕期货的许多 clojure 包装器中。最简单的只是一个函数，它接受两个函数并并行运行它们。

core> (defn conc [fn1 fn2] 
         (let [f1 (future (fn1)) 
               f2 (future (fn2))] [@f1 @f2]))
#'core/conc                                                                                    
core> (time (conc #(fn1 4) #(fn2 4)))
"Elapsed time: 3001.197634 msecs"

这避免了将其编写为宏的需要，方法是让 conc 将函数运行而不是主体进行评估，然后通过将调用放在#调用前面来创建要传递给它的函数。

这也可以用 map 和 future-call 来编写： 

core> (map deref (map future-call [#(fn1 4) #(fn2 42)]))
(5 84)

然后你可以改进 conc 直到它看起来像（正如 Julien Chastang 明智地指出的那样）pmap

于 2012-09-13T22:49:22.730 回答