server.clj

;; a simple server that's generating a new int that's < 100, every millisecond

(ns synchro.core
  (:import [org.jetlang.fibers ThreadFiber]))

(defonce server-list (atom []))

(defonce appender (atom nil))
(defonce fiber (doto (ThreadFiber.) .start))

(defn append-to-list []
  (when (< 9 (count @server-list))
    (swap! server-list butlast))
  (swap! server-list conj (rand-nth (range 100))))

(defn start []
  (reset! appender (.scheduleAtFixedRate fiber append-to-list 1 1 java.util.concurrent.TimeUnit/MILLISECONDS)))

(defn stop []
  (.dispose @appender))