From b7466fb13e40eb116c991b414445d35661019438 Mon Sep 17 00:00:00 2001 From: Rich Hickey Date: Wed, 29 Jan 2025 09:07:17 -0500 Subject: [PATCH] get out of executor datafy biz --- src/main/clojure/clojure/core/async/flow/impl.clj | 14 +------------- 1 file changed, 1 insertion(+), 13 deletions(-) diff --git a/src/main/clojure/clojure/core/async/flow/impl.clj b/src/main/clojure/clojure/core/async/flow/impl.clj index e296c83..b1a97a4 100644 --- a/src/main/clojure/clojure/core/async/flow/impl.clj +++ b/src/main/clojure/clojure/core/async/flow/impl.clj @@ -23,22 +23,10 @@ (defonce io-exec clojure.lang.Agent/soloExecutor) (defonce compute-exec clojure.lang.Agent/pooledExecutor) -(defn oid [x] - (symbol (str (-> x class .getSimpleName) "@" (-> x System/identityHashCode Integer/toHexString)))) - -(defn exec->data [exec] - (let [ess (as-> (str exec) ^String es - (.substring es (inc (.lastIndexOf es "[")) (.lastIndexOf es "]")) - (.split es ","))] - (merge {:id (oid exec) - :status (first ess)} ;;TODO less fragile - (zipmap [:pool-size :active-threads :queued-tasks :completed-tasks] - (map #(-> ^String % (.substring (inc (.lastIndexOf ^String % " "))) Long.) (rest ess)))))) - (defn datafy [x] (condp instance? x clojure.lang.Fn (-> x str symbol) - ExecutorService (exec->data x) + ExecutorService (str x) clojure.lang.Var (symbol x) (datafy/datafy x)))