2 files changed, 81 insertions, 0 deletions
diff --git a/vim/bundle/slimv/swank-clojure/swank/util/concurrent/mbox.clj b/vim/bundle/slimv/swank-clojure/swank/util/concurrent/mbox.clj
new file mode 100644
index 0000000..8c30d74
--- /dev/null
+++ b/vim/bundle/slimv/swank-clojure/swank/util/concurrent/mbox.clj
@@ -0,0 +1,31 @@
+(ns swank.util.concurrent.mbox
+  (:refer-clojure :exclude [send get]))
+
+;; Holds references to the mailboxes (message queues)
+(defonce mailboxes (ref {}))
+
+(defn get
+  "Returns the mailbox for a given id. Creates one if one does not
+   already exist."
+  ([id]
+     (dosync
+      (when-not (@mailboxes id)
+        (alter mailboxes assoc
+               id (java.util.concurrent.LinkedBlockingQueue.))))
+     (@mailboxes id))
+  {:tag java.util.concurrent.LinkedBlockingQueue})
+
+(defn send
+  "Sends a message to a given id."
+  ([id message]
+     (let [mbox (get id)]
+       (.put mbox message))))
+
+(defn receive
+  "Blocking recieve for messages for the given id."
+  ([id]
+     (let [mb (get id)]
+       (.take mb))))
+
+(defn clean []
+  )
diff --git a/vim/bundle/slimv/swank-clojure/swank/util/concurrent/thread.clj b/vim/bundle/slimv/swank-clojure/swank/util/concurrent/thread.clj
new file mode 100644
index 0000000..fa77a22
--- /dev/null
+++ b/vim/bundle/slimv/swank-clojure/swank/util/concurrent/thread.clj
@@ -0,0 +1,50 @@
+(ns swank.util.concurrent.thread
+  (:use (swank util)))
+
+(defn- gen-name []
+  (name (gensym "Thread-")))
+
+(defn start-thread
+  "Starts a thread that run the given function f"
+  ([#^Runnable f]
+     (doto (Thread. f)
+       (.start))))
+
+(defmacro dothread [& body]
+  `(start-thread (fn [] ~@body)))
+
+(defmacro dothread-keeping [bindings & body]
+  `(start-thread (keep-bindings ~bindings (fn [] ~@body))))
+
+(defmacro dothread-keeping-clj [more-bindings & body]
+  (let [clj-star-syms (filter #(or (= (name %) "*e")
+                                   (= (name %) "*1")
+                                   (= (name %) "*2")
+                                   (= (name %) "*3")
+                                   (and (.startsWith #^String (name %) "*")
+                                        (.endsWith #^String (name %) "*")
+                                        (> (count (name %)) 1)))
+                              (keys (ns-publics (find-ns 'clojure.core))))]
+    `(dothread-keeping [~@clj-star-syms ~@more-bindings]
+       ~@body)))
+
+(defn current-thread []
+  (Thread/currentThread))
+
+(defn thread-set-name
+  ([name] (thread-set-name (current-thread) name))
+  ([#^Thread thread name]
+     (.setName thread name)))
+
+(defn thread-name
+  ([] (thread-name (current-thread)))
+  ([#^Thread thread]
+     (.getName thread)))
+
+(defn thread-id
+  ([] (thread-id (current-thread)))
+  ([#^Thread thread]
+     (.getId thread)))
+
+(defn thread-alive? [#^Thread t]
+  (.isAlive t))