Skip to content

Commit 35b27bd

Browse files
committed
ASYNC-259 Implement go-checking with new executors
1 parent ecd324c commit 35b27bd

File tree

2 files changed

+25
-19
lines changed

2 files changed

+25
-19
lines changed

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

+7-6
Original file line numberDiff line numberDiff line change
@@ -13,8 +13,6 @@
1313

1414
(set! *warn-on-reflection* true)
1515

16-
(defonce ^:private in-dispatch (ThreadLocal.))
17-
1816
(defonce executor nil)
1917

2018
(defn counted-thread-factory
@@ -48,15 +46,18 @@
4846
any use of the async thread pool."
4947
(delay (or (Long/getLong "clojure.core.async.pool-size") 8)))
5048

49+
;; used only for implementing go-checking
50+
(def ^:private ^:dynamic *in-go-dispatch* false)
51+
5152
(defn in-dispatch-thread?
52-
"Returns true if the current thread is a go block dispatch pool thread"
53+
"Returns true if the current thread is used for go block dispatch"
5354
[]
54-
(boolean (.get ^ThreadLocal in-dispatch)))
55+
(boolean *in-go-dispatch*))
5556

5657
(defn check-blocking-in-dispatch
57-
"If the current thread is a dispatch pool thread, throw an exception"
58+
"If the current thread is being used for go block dispatch, throw an exception"
5859
[]
59-
(when (.get ^ThreadLocal in-dispatch)
60+
(when (in-dispatch-thread?)
6061
(throw (IllegalStateException. "Invalid blocking call in dispatch thread"))))
6162

6263
(defn ex-handler

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

+18-13
Original file line numberDiff line numberDiff line change
@@ -1041,18 +1041,23 @@
10411041
second
10421042
(emit-state-machine num-user-params user-transitions))))
10431043

1044+
(def ^:private go-checking (Boolean/getBoolean "clojure.core.async.go-checking"))
1045+
10441046
(defn go-impl
10451047
[env body]
1046-
(let [crossing-env (zipmap (keys env) (repeatedly gensym))]
1047-
`(let [c# (clojure.core.async/chan 1)
1048-
captured-bindings# (Var/getThreadBindingFrame)]
1049-
(dispatch/run
1050-
(^:once fn* []
1051-
(let [~@(mapcat (fn [[l sym]] [sym `(^:once fn* [] ~(vary-meta l dissoc :tag))]) crossing-env)
1052-
f# ~(state-machine
1053-
`(do ~@body) 1 [crossing-env env] rt/async-custom-terminators)
1054-
state# (-> (f#)
1055-
(rt/aset-all! rt/USER-START-IDX c#
1056-
rt/BINDINGS-IDX captured-bindings#))]
1057-
(rt/run-state-machine-wrapped state#))))
1058-
c#)))
1048+
(let [crossing-env (zipmap (keys env) (repeatedly gensym))
1049+
run-body `(let [c# (clojure.core.async/chan 1)
1050+
captured-bindings# (Var/getThreadBindingFrame)]
1051+
(dispatch/run
1052+
(^:once fn* []
1053+
(let [~@(mapcat (fn [[l sym]] [sym `(^:once fn* [] ~(vary-meta l dissoc :tag))]) crossing-env)
1054+
f# ~(state-machine
1055+
`(do ~@body) 1 [crossing-env env] rt/async-custom-terminators)
1056+
state# (-> (f#)
1057+
(rt/aset-all! rt/USER-START-IDX c#
1058+
rt/BINDINGS-IDX captured-bindings#))]
1059+
(rt/run-state-machine-wrapped state#))))
1060+
c#)]
1061+
(if go-checking
1062+
(list 'binding ['clojure.core.async.impl.dispatch/*in-go-dispatch* true] run-body)
1063+
run-body)))

0 commit comments

Comments
 (0)