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
  18   (defmacro cell "Define a new cell."
  19     [name state]
  20     `(def ~name (agent ~state)))
  21
  22   (defmacro propagator "Define a new propagator."
  23     [name in-cells out-cells & body]
  24     `(do
  25        (defn ~(with-meta name
  26                 (assoc (meta name)
  27                   :in-cells in-cells :out-cells out-cells))
  28          ~in-cells ~@body)
  29        (doseq [cell# ~in-cells] (add-neighbor cell# ~name))
  30        ~name))
  31
  32   (defmacro run-propagator
  33     "Run a propagator, first collect the most recent values from all
  34   cells associated with the propagator, then evaluate."
  35     [propagator]
  36     `(let [run-me# (fn [_#]
  37                      (apply ~propagator (map deref (:in-cells ^#'~propagator))))]
  38        (map (fn [cell#] (send cell# run-me#)) (:out-cells ^#'~propagator))))
  39
  40   (defmacro add-neighbor "Add a neighbor to the given cell."
  41     [cell neighbor]
  42     `(add-watcher
  43       ~cell :send
  44       (agent nil :validator (fn [_#] (do (future (run-propagator ~neighbor)) true)))
  45       (fn [_# _#])))
  46 #+end_src
  47
  48 * notes
  49 ** look at mutable data stores
  50 - http://clojure.org/agents
  51 - http://clojure.org/atoms
  52 - http://clojure.org/refs
  53
  54 most definitely will use agents, functions to set their values are
  55 applied to them with send (or send-off if potentially I/O bound), they
  56 support validators, and they can be set to run actions (i.e. alert
  57 propagators) as part of their update cycle.
  58
  59 ** design to permit distribution across multiple machines
  60 it should be possible to wrap these mutable items including
  61 - network connections from other machines
  62 - hardware (timers, I/O devices, etc...)
  63
  64 in cells, so that the propagator system remains "pure"
  65
  66 ** ask for advice
  67 This probably mentioned a request for advice from the mailing list or
  68 from the #clojure group.
  69