В библиотеке core.async мы видим файл макрос, создающий конечный автомат , который охватывает go блоков для создания каналов, которые обрабатывают блокировка ввода-вывода. Похоже, это моделирование C# async и на горутины Go-lang ....

Я написал автономный uberjar с основным методом, который запускает два блока go следующим образом: (defn -main [& args] (let [c (chan)] (go (while true (>! c (rand)))) (go (while true (<! c))))) Но...

все слишком часто, когда я использую core.async из блока repl, a go ускользает от меня, потому что я теряю канал, который используется для его остановки, потому что я перезагружаю пространство имен. Например, если я запускаю это из repl: (go...

Я пытаюсь создать приложение Clojurescript, которое показывает рецепты. Далее следует соответствующий код (также доступен как суть ): (defn load-recipes [data] (go (if (not (:loaded? @data)) (let [recipes-data (<! (fetch-recipes...

(ns example.asyncq (:require [cljs.core.async :as async] goog.async.AnimationDelay) (:require-macros [cljs.core.async.macros :refer [go go-loop]])) (defn loop-fx-on-atm-when-pred?-is-true [atm fx pred?] (let [c (async/chan) f...

Учитывая канал в ClojureScript (def navigation (chan)) Возможно ли иметь несколько блоков go, которые извлекают из него значения? Например. (go (while true (secretary/dispatch! (<! navigation)))) (go (while true (println...

Почему Alpha останавливается раньше, когда я ожидаю, что она будет вести себя как Beta? Единственная разница между Alpha и Beta — это >! и put! , как указано ниже. Альфа: user=> (def q (chan)) #'user/q user=> (def counter (atom...

У меня есть поток входных данных, и я хочу сделать 2 HTTPS сетевых запроса для каждого, прежде чем передавать результат в другую часть программы. Типичная пропускная способность составляет 50 в секунду. for each input: HTTP request A...

Я пытаюсь использовать библиотеку Clojure core.async для использования/обработки строк из файла. Когда мой код выполняется, IOException: Stream closed является броском. Ниже приведен сеанс REPL, который воспроизводит ту же проблему, что и в...

У меня внутренний конфликт по поводу использования Thread/sleep внутри блока go Clojure. Обычно не рекомендуется иметь какие-либо длительные процессы внутри блоков go, и Stuart Sierra упоминает, что сон в блоке go не предпочтителен : В общем,...

(let [a (clojure.core.async/chan)] (case a a :foo :bar)) #=> :bar Я бы ожидал :foo здесь. Что я делаю не так? С другой стороны, (condp = chan ...) выполняет свою работу. PS: В основном я пытаюсь сделать следующее:...

я не занимался Clojure пару лет, поэтому решил вернуться и не игнорировать core.async на этот раз) довольно крутая штука, но это меня почти сразу удивило. Теперь я понимаю, что существует неотъемлемая индетерминизм, когда задействовано несколько...

Насколько мне известно, асинхронные приложения с пулом потоков используются для того, чтобы не создавать новый поток для каждого соединения. Когда это решается с помощью блоков go в core.async, где сокет IO может быть припаркован, как это возможно...

Я использую Clojure core.async в программе сервлета. Я подозреваю утечку памяти в программе, и я обнаружил, что общее количество живых потоков не уменьшается, когда я отменяю развертывание своего приложения с сервера приложений (Glassfish). У...