propagator.org

   1 #+TITLE: Concurrent Propagator System
   2 #+OPTIONS: num:nil ^:nil
   3 #+LaTeX_CLASS: normal
   4
   5 * code
   6   :PROPERTIES:
   7   :tangle:   src/propagator.clj
   8   :END:
   9
  10 #+begin_src clojure
  11   (ns
  12       #^{:author "Eric Schulte",
  13          :license "GPLV3",
  14          :doc "Simple concurrent propagator system."}
  15     propagator
  16     (:use clojure.contrib.repl-utils
  17           clojure.contrib.duck-streams))
  18
  19   (defmacro cell "Define a new cell."
  20     [name state]
  21     `(def ~name (agent ~state)))
  22
  23   (defmacro propagator "Define a new propagator."
  24     [name in-cells out-cells & body]
  25     `(do
  26        (defn ~(with-meta name
  27                 (assoc (meta name)
  28                   :in-cells in-cells :out-cells out-cells))
  29          ~in-cells ~@body)
  30        (doseq [cell# ~in-cells]
  31          (println (format "adding %S to %S" ~name cell#))
  32          (add-neighbor cell# ~name))
  33        ~name))
  34
  35   (defmacro run-propagator
  36     "Run a propagator, first collect the most recent values from all
  37   cells associated with the propagator, then evaluate."
  38     [propagator]
  39     `(let [run-me# (fn [_#]
  40                     (apply ~propagator (map deref (:in-cells ^#'~propagator))))]
  41        (map (fn [cell#] (send cell# run-me#)) (:out-cells ^#'~propagator))))
  42
  43   (defmacro add-neighbor "Add a neighbor to the given cell."
  44     [cell neighbor]
  45     `(add-watcher
  46       ~cell :send
  47       (agent nil :validator
  48              (fn [_#]
  49                (run-propagator ~neighbor)
  50                (append-spit "/home/Desktop/spitoon" (~neighbor))
  51                true))
  52       (fn [_# _#])))
  53 #+end_src
  54
  55 * notes
  56 ** look at mutable data stores
  57 - http://clojure.org/agents
  58 - http://clojure.org/atoms
  59 - http://clojure.org/refs
  60
  61 most definitely will use agents, functions to set their values are
  62 applied to them with send (or send-off if potentially I/O bound), they
  63 support validators, and they can be set to run actions (i.e. alert
  64 propagators) as part of their update cycle.
  65
  66 ** design to permit distribution across multiple machines
  67 it should be possible to wrap these mutable items including
  68 - network connections from other machines
  69 - hardware (timers, I/O devices, etc...)
  70
  71 in cells, so that the propagator system remains "pure"
  72
  73 ** ask for advice
  74 This probably mentioned a request for advice from the mailing list or
  75 from the #clojure group.
  76