Add dispatch.clj

Author: dmiller

src/main/clojure/clojure/core/async/impl/dispatch.clj

@@ -0,0 +1,36 @@
+
+;;   Copyright (c) Rich Hickey and contributors. All rights reserved.
+;;   The use and distribution terms for this software are covered by the
+;;   Eclipse Public License 1.0 (http://opensource.org/licenses/eclipse-1.0.php)
+;;   which can be found in the file epl-v10.html at the root of this distribution.
+;;   By using this software in any fashion, you are agreeing to be bound by
+;;   the terms of this license.
+;;   You must not remove this notice, or any other, from this software.
+
+(ns ^{:skip-wiki true}
+  clojure.core.async.impl.dispatch
+  (:require [clojure.core.async.impl.protocols :as impl]
+            [clojure.core.async.impl.exec.threadpool :as tp]))
+
+(set! *warn-on-reflection* true)
+
+;;;(defonce ^:private in-dispatch (ThreadLocal.))
+
+(defonce executor
+  (delay (tp/thread-pool-executor )))    ;;;  #(.set ^ThreadLocal in-dispatch true)  -- getting rid of this init-fn.
+
+(defn in-dispatch-thread?
+  "Returns true if the current thread is a go block dispatch pool thread"
+  []
+  false)                                ;;; we have no way to detect (boolean (.get ^ThreadLocal in-dispatch))
+
+(defn check-blocking-in-dispatch
+  "If the current thread is a dispatch pool thread, throw an exception"
+  []                                   ;;; making this a no-op
+  )                                    ;;; (when (.get ^ThreadLocal in-dispatch)
+                                       ;;;   (throw (IllegalStateException. "Invalid blocking call in dispatch thread")))
+
+(defn run
+  "Runs Runnable r in a thread pool thread"
+  [r]                                            ;;; ^Runnable  -- we don't have this type.  We are set up to take an IFn -- it will be called with no args
+  (impl/exec @executor r))