1 parent 300d6e1 commit 3429e3eCopy full SHA for 3429e3e
1 file changed
src/main/clojure/clojure/core/async.clj
@@ -503,14 +503,10 @@ the Java system property `clojure.core.async.pool-size`."
503
true)))]
504
(dotimes [_ n]
505
(case type
506
- :blocking (thread
507
- (let [job (<!! jobs)]
508
- (when (process job)
509
- (recur))))
510
- :compute (go-loop []
511
- (let [job (<! jobs)]
512
513
+ (:blocking :compute) (thread
+ (let [job (<!! jobs)]
+ (when (process job)
+ (recur))))
514
:async (go-loop []
515
(let [job (<! jobs)]
516
(when (async job)
0 commit comments