diff options
| -rw-r--r-- | src/clj/clojure/core.clj | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/src/clj/clojure/core.clj b/src/clj/clojure/core.clj index 8d3eef21..ca3acfac 100644 --- a/src/clj/clojure/core.clj +++ b/src/clj/clojure/core.clj @@ -3704,6 +3704,19 @@ "Returns true if coll implements Reversible" [coll] (instance? clojure.lang.Reversible coll)) +(defn pcalls + "Executes the no-arg fns in parallel, returning a lazy sequence of + their values" + [& fns] + (let [futs (.invokeAll clojure.lang.Agent/pooledExecutor fns)] + (map #(.get %) futs))) + +(defmacro pvalues + "Returns a lazy sequence of the values of the exprs, which are + evaluated in parallel" + [& exprs] + `(pcalls ~@(map #(list `fn [] %) exprs))) + (defn pmap "Like map, except f is applied in parallel. Semi-lazy in that the parallel computation stays ahead of the consumption, but doesn't |