未来是否总是创建一个新线程？

Question

假设我这样做：

(future
  (do-the-thing))

我是否可以保证，无论 (do-the-thing) 做什么，

• 将创建一个全新的线程，而不是从池中获取一个或类似的东西？
• 除了(do-the-thing) 之外的任何东西都不会在该新线程上运行？
• 一旦(do-the-thing) 在那个新线程上执行，线程会终止吗？

如果不是，在什么情况下这些假设是错误的？

Answer 1

简短的回答是否

来自clojure的core.clj：

(defmacro future
...
  [& body] `(future-call (^{:once true} fn* [] ~@body)))
...

(defn future-call 
...
  [f]
  (let [f (binding-conveyor-fn f)
        fut (.submit clojure.lang.Agent/soloExecutor ^Callable f)]
...

所以未来的执行者是clojure.lang.Agent/soloExecutor。

来自Agent.java：

volatile public static ExecutorService soloExecutor = Executors.newCachedThreadPool(
    createThreadFactory("clojure-agent-send-off-pool-%d", sendOffThreadPoolCounter));

可以看到soloExecutor是由Executors.newCachedThreadPool()创建的

来自document of Executors.newCachedThreadPool：

创建一个线程池，根据需要创建新线程，但在可用时将重用以前构造的线程。这些池通常会提高执行许多短期异步任务的程序的性能。如果可用，对执行的调用将重用以前构造的线程。如果没有可用的现有线程，将创建一个新线程并将其添加到池中。六十秒内未使用的线程将被终止并从缓存中删除。因此，保持空闲足够长时间的池不会消耗任何资源。请注意，可以使用 ThreadPoolExecutor 构造函数创建具有相似属性但细节不同（例如超时参数）的池。

所以答案是(do-the-thing) 的其他工作可能在同一个线程中执行，如果没有更多工作，该线程将在 60 秒后终止。

您可以在以下代码中确认Executors.newCachedThreadPool 的行为：

(doseq [i (for [x (range 10)] (future (Thread/sleep 1000) (.getId (Thread/currentThread))))] (print @i) (print " "))

在clojure控制台执行这段代码，你会得到：

50 49 48 47 46 45 44 43 42 41 nil

第一次。 5秒后再次执行，得到：

50 49 43 41 45 42 46 47 48 44 nil

因此你可以确认线程被重用了。

如果你在 60 秒后执行相同的代码，你会得到：

60 59 58 57 56 55 54 53 52 51 nil

因此您可以确认之前的线程已终止并创建了新线程。