core.async

7ısı

1cevap

Dönüştürücülerden başka bir kanal nasıl oluşturulur?

Sadece belirli mesajları filtreleyen başka bir kanaldan clojure.core.async bir kanal oluşturmak istiyorum. Bu nedenle filtre < adlı bir işlev buldum. => (def c1 (chan)) => (def c2 (filter< even? c1))

clojure core.async transducer 2015-07-08

---

12ısı

1cevap

Sıralı İşlemleri İletmek [CSP] Scala'daki aktör modeline bir alternatif mi?

1978 Paper by Hoare we have an idea called Communicating Sequential Processes'da. Bu Go, Occam ve Clojure'de core.async'da kullanılır. Scala'da Aktör Modeline alternatif olarak CSP kullanmak mümkün mü

scala core.async actor-model 2013-11-24

---

0ısı

1cevap

Git blokları ile clojure kodu yapılandırma

Asenkronize halka bağdaştırıcısı için jet kullanıyorum. Jet ayrıca, :body değeri de bir kanal olan bir kanalı döndüren async http-client ile birlikte gelir. Ayrıca, eşzamansız sunucu yol işleyicisi, :

asynchronous clojure core.async 2016-03-21

---

5ısı

1cevap

Clojure async kanalı için beklemenin yolu nedir?

Bu, çok basit bir iş yapan kodun geçerli sürümüdür. Bu 10 go rutinleri başlatıyor ve her rutin, kanala 10 mesaj ekliyor. Diğer uç, kanalı okuyan ve her 500 ms'de bir zaman geçiren bir süre gerçek döng

clojure core.async 2014-11-13

---

1ısı

1cevap

core.async git blokları neden bir kanal döndürüyor?

"Git blokları" nın (go veya go-loop veya diğer yapıların) bir kanal döndürdüğünü anlıyorum. Ancak bu kanalın amacını hiç anlamadım. Nasıl kullanılacağını bilmek isterim. Belki de ihtiyacım olmadığında

clojure core.async 2016-03-26

---

5ısı

1cevap

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

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'dek

clojure clojurescript core.async 2015-11-09

---

1ısı

1cevap

core.async geçiş kanalı karışımı

Core.async'in karışımlarını deniyorum. Bir karışımda bir giriş kanalının susturulması, geri tepmeyi gerçekleştirmenin olası yollarından biri olacaktır. Ben aşağıdaki kodu kullanıyorum: REPL CompilerEx

clojure core.async backpressure 2016-04-11

---

5ısı

1cevap

Neden clojure içinde core.async için iş parçacığı, çekirdek sayısı 2 artı 42? çekirdeklerinin

core.async Clojure kütüphanede threadpool implementation boyutta bir FixedThreadPoolExecutor kullanır = # * 2 + 42. (defonce the-executor (Executors/newFixedThreadPool (-> (Runtime/getRuntim

clojure core.async 2014-10-17

---