quasar producer

core.clj

(ns clj-quasar.core
  (:require
   [co.paralleluniverse.pulsar
    [core :refer :all]
    [actors :refer :all]]))

(defsfn adder []
  (receive [from v]
           (do 
             (+ v 1))))


(defsfn producer []
  (loop [state (rand)]
    (println "state:" state)
    (receive [from :send]
             (let [a1 (spawn adder)
                   a2 (spawn adder)]

               (! a1 @self state)
               (! a2 @self state)
               
               (recur (+ state 
                         (+ (join a1) (join a2)))))
             )))

(def p (spawn producer))

(def workder 
  (future (while true 
            (do 
              (! p @self :send)
              (Thread/sleep 2000) 
              ))))

(comment
  (future-cancel worker))