İletiler, core.async ile doğru şekilde nasıl toplu işlenir?

Question

Bir core.async anahtarında iletileri ve zaman aşımına göre (ör. 10 ms veya 10 mesaj, hangisi önce gelirse) toplu olarak göndermek istiyorum. Tim Baldridge has a video on batching, ancak core.async'deki onaylanmamış işlevleri kullanır ve dönüştürücü kullanmaz. Ben ... Aşağıdaki gibi bir şey arıyorum

(defn batch [in out max-time max-count] 
    ... 
) 

Answer 1

Transdüserler gerçekten harmanlama işlevi için bir endişe olmamalı -, bu konuda herhangi bir dönüştürücüler tarafından dönüştürülmüş değerleri göreceksiniz in kanalda bir içe alan olarak Kanal ve out'da dinleyen tüm katılımcılar, bu kanalın dönüştürücüsü tarafından dönüştürülen değerleri görecektir. giriş kanalı kapattığında

, kapanış, out için tabi bunları bir uygulama gelince, aşağıda işlev in den max-count öğelerin toplu alacak veya son toplu çıkış beri ancak birçok max-time varmak ve çıkış giriş kanalının dönüştürücü (eğer varsa ve out dinleme herhangi girenlerin aynı zamanda, yukarıda belirtildiği gibi, kanalın dönüştürücü uygulanan olacaktır): basit ve doğru kodun, bir

(defn batch [in out max-time max-count] 
    (let [lim-1 (dec max-count)] 
    (async/go-loop [buf [] t (async/timeout max-time)] 
     (let [[v p] (async/alts! [in t])] 
     (cond 
      (= p t) 
      (do 
      (async/>! out buf) 
      (recur [] (async/timeout max-time))) 

      (nil? v) 
      (if (seq buf) 
      (async/>! out buf)) 

      (== (count buf) lim-1) 
      (do 
      (async/>! out (conj buf v)) 
      (recur [] (async/timeout max-time))) 

      :else 
      (recur (conj buf v) t))))))