diff options
| author | Rich Hickey <richhickey@gmail.com> | 2009-03-01 22:53:55 +0000 |
|---|---|---|
| committer | Rich Hickey <richhickey@gmail.com> | 2009-03-01 22:53:55 +0000 |
| commit | 115bbb2f79465010dde4dc189af10fc9d4f1f4b4 (patch) | |
| tree | 02dd93a6401b8f807958329af981209db3f77bd2 /src | |
| parent | 2fd3186c3502e34201a9803a1bb62bb7a9b01604 (diff) | |
made futures use CachedThreadPool
Diffstat (limited to 'src')
| -rw-r--r-- | src/clj/clojure/core.clj | 2 | ||||
| -rw-r--r-- | src/jvm/clojure/lang/Agent.java | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/src/clj/clojure/core.clj b/src/clj/clojure/core.clj index 90566791..00749700 100644 --- a/src/clj/clojure/core.clj +++ b/src/clj/clojure/core.clj @@ -3998,7 +3998,7 @@ return it on all subsequent calls to deref/@. If the computation has not yet finished, calls to deref/@ will block." [#^Callable f] - (let [fut (.submit clojure.lang.Agent/pooledExecutor f)] + (let [fut (.submit clojure.lang.Agent/soloExecutor f)] (proxy [clojure.lang.IDeref java.util.concurrent.Future] [] (deref [] (.get fut)) (get ([] (.get fut)) diff --git a/src/jvm/clojure/lang/Agent.java b/src/jvm/clojure/lang/Agent.java index 3737805d..310c826b 100644 --- a/src/jvm/clojure/lang/Agent.java +++ b/src/jvm/clojure/lang/Agent.java @@ -25,7 +25,7 @@ volatile Object state; final public static ExecutorService pooledExecutor = Executors.newFixedThreadPool(2 + Runtime.getRuntime().availableProcessors()); -final static ExecutorService soloExecutor = Executors.newCachedThreadPool(); +final public static ExecutorService soloExecutor = Executors.newCachedThreadPool(); final static ThreadLocal<IPersistentVector> nested = new ThreadLocal<IPersistentVector>(); |