Как предотвратить близко! -ную, прежде чем ставить-ки в онто-чан

Question

Я хотел бы запустить код как

(->> input 
    (partition-all 5) 
    (map a-side-effect) 
    dorun) 

асинхронно разделив вход и выход (а-побочный эффект).

Затем я написал код для эксперимента ниже.

;; using boot-clj 
(set-env! :dependencies '[[org.clojure/core.async "0.2.374"]]) 
(require '[clojure.core.async :as async :refer [<! <!! >! >!!]]) 

(let [input (range 18) 
     c (async/chan 1 (comp (partition-all 5) 
          (map prn)))] 
    (async/onto-chan c input false) 
    (async/close! c)) 

объяснение этого кода:

• Собственно элементы ввода и его количество не определено перед запуском и элементов на входе может быть принято некоторыми числами от 0 до 10.
• async/onto-chan используется для помещения Seq элементов (фрагмента ввода) в канал c и будет вызываться много раз, поэтому третий аргумент false.
• prn является заменой для a-side-effect.

Я ожидал, что приведенный выше код печатает

[0 1 2 3 4] 
[5 6 7 8 9] 
[10 11 12 13 14] 
[15 16 17] 

в РЕПЛ однако он не печатает никаких символов.

А потом я добавить время, чтобы ждать, как этот

(let [c (async/chan 1 (comp (partition-all 5) 
          (map prn)))] 
    (async/onto-chan c (range 18) false) 
    (Thread/sleep 1000) ;wait 
    (async/close! c)) 

Этот код дал мой ожидаемый результат выше.

И затем я проверяю core.async/onto-chan.

И я думаю, что случилось:

1. канал c был core.async/close! редактор в моем коде.
2. каждый пункт аргумента core.async/onto-chan был поставлен (core.async/>!) напрасно в go-loop в onto-chan, потому что канал c был закрыт.

Есть ли способ положить предметы до close! ing? написать синхронную версию onto-chan не используя go-loop?

Или моя идея не так? Идея

Answer 1

Ваш второй пример с Thread.sleep только «работает» по ошибке.

Причина это работает, что каждый преобразуется значение результата, который выходит из преобразователя c «s является nil, а так nil s не допускается в каналах, генерируется исключение, и никакого значения не помещаются в c: это что позволяет продюсеру onto-chan продолжать поместить в канал, а не ждать блока.Если вы вставляете второй пример в REPL, вы увидите четыре трассировки стека - по одному для каждого раздела.

nil s, конечно, связано с отображением над prn, что является функцией побочного эффекта, которая возвращает nil для всех входов.

Если я правильно понял ваш дизайн правильно, ваша цель состоит в том, чтобы сделать что-то вроде этого:

(defn go-run! [ch proc] 
    (async/go-loop [] 
    (when-let [value (<! ch)] 
     (proc value) 
     (recur)))) 

(let [input (range 18) 
     c (async/chan 1 (partition-all 5))] 
    (async/onto-chan c input) 
    (<!! (go-run! c prn))) 

• Вы действительно нужен продюсер и потребитель, иначе ваша программа будет блокировать. Я ввел потребителя go-loop.
• В общем, map и побочные эффекты не идут хорошо, поэтому я извлек побочный эффект prn в потребитель.
• onto-chan нельзя назвать «много раз» (по крайней мере, в показанном коде), поэтому ему не нужен аргумент false.

Answer 2

если взять megakorre в:

(let [c (async/chan 1 (comp (partition-all 5) 
          (map prn))) 
     put-ch (async/onto-chan c (range 18) false)] 
    (async/alts!! [put-ch]) 
    (async/close! c))