ST
по привычке из предыдущих экспериментов
Size: a a a
2020 January 23
ST
убрал, чтобы не смущало
MB
1.5 часа работы, если не считать, что не мог утра дождаться 😊
Посмотрю, как от багфикса оторвусь)
IG
Кто в aleph понимает? Задал в слаке вопрос, молчат.
IG
What is the best way to implement a “worker” entity? By this I mean a separate loop/recur in the background which consumes a stream? Say I have a stream of events and would like to process them by four workers.
IG
(let [stream (get-stream)
number 4]
(doseq [n number]
(d/loop []
(let [message (get-from-stream stream)]
(process-message message)
(d/recur)))))
?
AK
Тебе, наверное, process-message в отдельной нити надо делать. Хотя, я aleph не юзал, хотел только.
AK
Хотя, в нити просто так не получится, тебе надо потом результат как-то в очередь положить, чтобы он отправил по ответу.
AK
В примерах, вроде, через d/future делают.
AK
В коде выглядит как бы последовательно, на самом деле отдельно происходит обработка.
AK
slow-echo-handler
ST
Посмотрю, как от багфикса оторвусь)
суровый, видать, баг попался 😊
MB
Ага, только вот закончил
MB
ООП очень "интересные" баги умеет порождать)
AR
(let [stream (get-stream)
number 4]
(doseq [n number]
(d/loop []
(let [message (get-from-stream stream)]
(process-message message)
(d/recur)))))
?
отправь
process-message в отдельный executor (фиксированного размера, например), коллбэком дергая d/recurAR
но тут от loop только проблем больше, проще без него
p
как ТГ графики рисовать, есть библиотеки Clojure?
T
как ТГ графики рисовать, есть библиотеки Clojure?
Что такое ТГ?
