dispatch/in-vthread?

Author: fogus

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

@@ -169,7 +169,7 @@ IOC and vthread code.
         blockingop (-> op name (str "!") symbol)]
     `(def ~(with-meta op {:arglists `(list ~as) :doc doc})
        (fn [~'& ~'args]
-         (if (= "VirtualThread" (.getSimpleName (class (Thread/currentThread))))
+         (if (dispatch/in-vthread?)
            ~(list* apply blockingop '[args])
            (assert nil ~(str op " used not in (go ...) block")))))))
 

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

@@ -91,6 +91,9 @@
   (and virtual-threads-available?
        (not= (vthreads-directive) "avoid")))
 
+(defn in-vthread? []
+  (= "VirtualThread" (.getSimpleName (class (Thread/currentThread)))))
+
 (defn report-vthreads-not-available-error! []
   (throw (ex-info "Code compiled to target virtual threads, but is running without vthread support."
                   {:runtime-jvm-version (System/getProperty "java.version")