Вопросы по теме 'core.async'

Похож ли Clojure core.async на OCaml Core Async Джейн Стрит?
В этом сообщении в блоге автор пишет: Однако Grenchman построен на основе библиотек Core и Async от Jane Street, одного из крупнейших промышленных пользователей OCaml. Async допускает монадический ложный параллелизм, который позволяет...
1023 просмотров

Расширение функциональности clojure core.async
Рекомендуется ли расширять функциональность core.async с помощью моих собственных асинхронных функций? Асинхронность каналов обрабатывается put! и take! , которые принимают обратные вызовы, но протоколы вложены в async.impl.protocols ....
462 просмотров
schedule 15.05.2023

Можно ли использовать реализацию core.async в ClojureScript в Clojure?
Можно ли использовать реализацию core.async на основе конечного автомата ClojureScript в Clojure, а не реализацию Clojure на основе потоков? Я хотел бы иметь возможность использовать core.async на JVM, но без использования потоков.
519 просмотров
schedule 14.07.2022

В чем преимущество core.async в clojurescript?
Все говорят о том, насколько хорош core.async и как он улучшит обработку событий в clojurescript. Я следил за руководством по ClojureScript 101 и не вижу явного преимущества из этих примеров кода. Что мне не хватает? Почему здесь лучше...
6698 просмотров
schedule 23.03.2023

Как вы записываете файл журнала в Clojure, используя core.async?
Я хочу использовать core.async в качестве регистратора, который записывает данные в файл, поэтому я создал файл test.txt, поместил его в папку ресурсов и написал такой код: (use 'clojure.java.io) (use 'clojure.core.async) (def print-chan (chan))...
1004 просмотров

core.async pub/sub ведет себя странно в Om (clojurescript)
Почему счетчик в дочернем компоненте обновляется нормально, когда я комментирую (om/update-state! owner :clicked not) а не когда я раскомментирую его в родительском компоненте в коде ниже? Счетчик обновляется нажатием кнопки. То, что я...
483 просмотров
schedule 29.03.2023

clojure.async: ‹! не в (перейти) ошибка блока
Когда я оцениваю следующий код clojurescript core.async, я получаю сообщение об ошибке: «Uncaught Error: ‹! Используется не в блоке (go...)» (let [chans [(chan)]] (go (doall (for [c chans] (let [x (<! c)] x))))) Что я...
251 просмотров
schedule 19.10.2023

Следует ли закрывать каналы clojure core.async, когда они больше не используются?
Метод Close (по крайней мере, в мире Java ) — это то, что вы, как добропорядочный гражданин, должны вызвать, когда закончите использовать соответствующий ресурс. Каким-то образом я автоматически начал применять то же самое для функции close! из...
1247 просмотров
schedule 09.06.2023

любое простое решение для использования асинхронного ядра clojure с кольцом (адаптер vertx/ring)
что может быть лучшим способом обработки асинхронных каналов в кольце, в основном мне нужно получить ответ моего канала внутри моего обработчика, а затем обслужить ответ (GET "/slow/:a" [a] (slow-request2 a)) ;;this function do a slow operation...
564 просмотров
schedule 25.04.2022

Когда канал будет отброшен, если поток продолжает его использовать?
Рассмотрим следующий фрагмент кода, взятый из пример обхода core.async : (let [c1 (chan) c2 (chan)] (thread (while true (let [[v ch] (alts!! [c1 c2])] (println "Read" v "from" ch)))) (>!! c1 "hi")...
200 просмотров
schedule 08.12.2023

Clojurescript — необработанная ошибка: ‹! используется не в блоке (go)
Я работаю в Clojurescript и пытаюсь использовать core.async , чтобы получить результат от собственной функции Javascript (я am в браузере) и условно интегрировать его в карту. У меня есть функция для обертывания собственного вызова браузера...
455 просмотров
schedule 25.01.2024

Дроссельные функции с core.async
Количество возможных исполнений функции должно быть ограничено. Таким образом, после вызова функции любой повторный вызов следует игнорировать в течение определенного периода времени. Если в это время есть вызовы, последний должен быть выполнен...
1325 просмотров
schedule 31.10.2023

Структурирование кода clojure с помощью блоков go
Я использую jet для асинхронного кольцевого адаптера. Jet также поставляется с асинхронным http-клиентом, который возвращает канал, значение которого :body также является каналом. Кроме того, обработчик маршрута асинхронного сервера может...
241 просмотров
schedule 17.01.2024

Почему блоки core.async go возвращают канал?
Я понимаю, что «блоки перехода» (будь то go или go-loop или, возможно, другие конструкции) возвращают канал. Однако я никогда не понимал предназначения этого канала. Я хотел бы знать, как его использовать. Возможно, я создаю дополнительные...
865 просмотров
schedule 11.11.2023

Цикл core.async заблокирован в ожидании чтения из канала
скажем, у меня есть канал out (chan) . Мне нужно взять значения, которые помещаются в канал, и добавить их. Количество значений не определено (поэтому нельзя использовать традиционный цикл с конечным регистром (<! out) ) и исходит от внешнего...
212 просмотров
schedule 07.02.2023

Нужно оптимизировать мой код Clojure, который занимает слишком много времени
У меня есть файл журнала размером 1,6 ГБ, содержащий 2 миллиона записей. Я читаю содержимое журнала в канал, выполняю некоторые преобразования и записываю содержимое обратно в другой канал. Наконец, я записываю содержимое второго канала в файл....
181 просмотров
schedule 31.08.2023

core.async переподключение веб-сокета
core.async нуб здесь, но пытаюсь учиться, создавая автоматически переподключающийся веб-сокет. Идея состоит в том, что сокет абстрагируется, так что любому, кто его использует, не нужно беспокоиться о том, подключен он или нет, и он может просто...
140 просмотров
schedule 12.03.2023