🍵

dovrebbe essere un the' ma non e' verde quello che ho ora...

😂

pmap mi confonde sempre. pmap con non-lazy sequence, esegue max 32 thread concorrenti (apparentmente la grandezza del send-off-agent pool). Con lazy seq usa num.core+2 threads alla volta.

@reborg https://github.com/TheClimateCorporation/claypoole

bookmark... userei se ho bisogno di controllare larghezza dei pool e non interferire col send-off di clj

@reborg non e` proprio cosi`

e` una questione di chunked coll vs non chunked coll

niente a che vedere con la send-off agent pool

pmap essenzialmente fa (map #(future (f %)) coll) e poi ne dereffa num-core+2 per far partire i future concorrenti

se coll e` chunked pero`, al deref del primo elemento, map esegue eagerly chunk-size elementi (32)

orko si, ho appena riguardato il sorgente

i 32 erano molto sospetti come numero

ne segue che non c'e' modo di eseguire piu' di 32 (con lazy-seq della std lib)

in che senso?

e num-core > 30 pmap eseguira` piu` di 32 in parallelo

non riesco a vederne di piu'... gliene do' 250 e ne vedo 32 alla volta

(let [pi (fn [n] (->> (range) (filter odd?) (take n) (map / (cycle [1 -1])) (reduce +) (* 4.0)))
      coll (vec (range 2000 2250))]
  (pmap pi coll))

con "pi" per scaldare la cpu

eh si` perche` il tuo numero di core + 2 e` < 32

quindi e` cappato da chunk-size

ah si ho capito