core-async 2022-03-23 | Slack Archive

popeye09:03:11

(->> data
       (fn []  (.....transformation logic..))
       (async/merge)
       (async/reduce conj [])
       (async/<!!))

i have written above code , How can I make async number of threads configurable ?

Ferdinand Beyer10:03:05

Using the clojure.core.async.pool-size system property, see: https://github.com/clojure/core.async/blob/master/src/main/clojure/clojure/core/async/impl/exec/threadpool.clj#L16

Jakub Holý (HolyJak)12:03:49

Does it make sense to configure it? Ie do you need something else than thread / cpu? If you can change the code then you could look at async/pipeline,I think.

2022-03-23

Channels