Я немного работал с core.async (на стороне сервера) и задал вопрос о распределении потоков в цикле core.asyc go. Если я имел следующий идти-блок (go (while true
(let [[v ch] (alts!! [@app/p4])]
Я экспериментирую с минами core.async. Похоже, что подавление входного канала в смеси будет одним из возможных способов реализации противодавления. Я использую ниже код: (def output-chan (chan))
(def
У меня есть следующий код: (defn -db-producer-factory [order-ids-chan next-chan]
(thread
(prn "db starting...")
(while true
(do
(prn "db starting2...")
;;
;; iss
Я этот производитель/потребитель модель я уже делал с core.async thread функции следующим образом: (defn -db-producer-factory [order-ids-chan next-chan]
(thread
(while true
(do
(
Я хотел бы запустить код как (->> input
(partition-all 5)
(map a-side-effect)
dorun)
асинхронно разделив вход и выход (а-побочный эффект). Затем я написал код для эксперимента ниже. ;