IG
Мы одно время кувыркались с кафкой и async, была даже своя либа для этого. Там не все так просто. Объект Consumer в кафке можно трогать только из того треда, в котором он создан, иначе будет исключение.
Size: a a a
2021 January 28
AC
да, это я понимаю. а с core.async разве не так же? читаю из коннекта, беру список подписчиков из атома и им шлю
AC
у меня не кафка, а apache pulsar
IG
Про пульсар я не в курсе, но все равно же будет какой-то тред, который поллит источник. Он явно будет жить в своем потоке.
IG
Не создавать же новый Consumer на каждую итерацию
AC
да, так и есть. у меня на яве выписан уже код через тред, вот думал, может какой сахарок в кложе есть...
IG
Проще Consumer в свой тред поселить и пусть там колбасится.
AC
тред тупо читае все сообщения из очереди и их публикует в ConcurentQueue (это я на яве так делал), аздесь тупо атом использую
AC
я про треды и спрашиваю, может какой сахар есть?
IG
Можно написать простой макрос
with-thread, который принимает тело и возвращает экземпляр тредаIG
но это несущественно
IG
(defmacro with-thread
[& body]
`(let [thread# (new Thread (fn [] ~@body))]
(.start thread#)
thread#))
(def t (with-thread (println 42)))
(.join t)
IG
а чтобы послать сообщение консьюмеру в тред, использовать атом, агент или промис
TL
(defmacro with-thread
[& body]
`(let [thread# (new Thread (fn [] ~@body))]
(.start thread#)
thread#))
(def t (with-thread (println 42)))
(.join t)
Код выглядит как плохой совет. Мне кажется, никогда так не правильно.
TL
Новичку, который даже не разбирался с async — предлагается писать макросы.
KC
ну макросы все таки фундаментальны в clojure, тогда как core.async это библиотека
KC
да и разобраться в них попроще (имхо) чем набить шишек с core.async
TL
Максоры — это всё-таки для продвинутых чуваков, иначе это слишком острый инструмент, который плодит говнокод со страшной силой.
TL
А core.async — кор-библиотека примитивов асинхронности. Как мне кажется, макросы примерно через год после core.async стоит начинать использовать новичку.
KC
но она (core.async) тоже на макросах почти полностью )
как без их понимания в ошибках разбираться?
как без их понимания в ошибках разбираться?