Clojure dothreads！功能

Question

我读Fogus的书上的Clojure的喜悦，并在并行编程章我看到一个函数定义这肯定想说明一些重要的东西，但我无法找出什么。此外，我看不出这是什么功能 - 当我执行，它不会做任何事情：

(import '(java.util.concurrent Executors)) 
    (def *pool* (Executors/newFixedThreadPool 
    (+ 2 (.availableProcessors (Runtime/getRuntime))))) 

(defn dothreads! [f & {thread-count :threads 
         exec-count :times 
         :or {thread-count 1 exec-count 1}}] 
    (dotimes [t thread-count] 
    (.submit *pool* #(dotimes [_ exec-count] (f))))) 

我试图以这种方式运行：

(defn wait [] (Thread/sleep 1000)) 
(dothreads! wait :thread-count 10 :exec-count 10) 
(dothreads! wait) 
(dothreads! #(println "running")) 

...但它返回nil。为什么？

Answer 1

所以，在这里是相同的代码，以便传递给dothreads!这个函数会得到内部dotimes的数量略有微调。

(import 'java.util.concurrent.Executors) 

(def ^:dynamic *pool* (Executors/newFixedThreadPool (+ 2 (.availableProcessors (Runtime/getRuntime))))) 

(defn dothreads! [f & {thread-count :threads 
         exec-count :times 
         :or {thread-count 1 exec-count 1}}] 
    (dotimes [t thread-count] 
    (.submit *pool* #(dotimes [c exec-count] (f c))))) 

(defn hello [name] 
    (println "Hello " name)) 

尝试运行它像这样：

(dothreads! hello :threads 2 :times 4) 

对于我来说，它打印东西的效果：

Hello 0 
Hello 1 
Hello 2 
Hello 3 
nil 
user=> Hello 0 
Hello 1 
Hello 2 
Hello 3 

所以，注意你调用函数时犯了一个错误：您在通过：线程数和：EXEC数作为关键字，而这些其实都是在T绑定他解构了dothreads!内部发生的事情。关键字是开始以一个冒号，:threads和:times的话。

至于这是什么代码实际上做：

1. 它创建最多将使用你的机器+ 2的 芯数的新的固定大小的线程池。该池称为*pool*并使用的Java执行器框架创建。有关更多详细信息，请参见[1]。

2. 的dothreads!函数获取将要在每个thread-count线程称为exec-count次功能。所以，在上面的例子中，你可以清楚地看到它被称为每一个线程4倍（:threads为2和:times为4）。

3. 此函数返回nil的原因是函数dothreads!不返回任何内容。线程池的submit方法在Java中返回void，这意味着它在Clojure中返回nil。如果要在使之成为函数的末尾添加一些其它表达：

   (defn dothreads! [f & {thread-count :threads 
            exec-count :times 
            :or {thread-count 1 exec-count 1}}] 
       (dotimes [t thread-count] 
       (.submit *pool* #(dotimes [c exec-count] (f c)))) 
       (* thread-count exec-count)) 
   

它将返回8上面的例子（2 * 4）。只有函数中的最后一个表达式被返回，所以如果在函数中你要写(fn [x y] (+ x y) (* x y))这将始终返回该产品。总和将被评估，但它将为没有任何。所以，不要这样做！如果你想添加一个表达式到一个函数，确保除了最后一个都有副作用，否则它们就没用了。

1. 你也可能注意到了，在其中打印东西的顺序是异步的。所以，在我的机器上，它会打4声，然后返回函数的结果，然后再打4声。线程之间执行函数的顺序是不确定的，但是每个线程中的hello都是顺序的（在Hello 2之前永远不会有Hello 3）。究其原因，顺序性是实际提交给线程池的功能是#(dotimes [c exec-count] (f c))和

[1] http://download.oracle.com/javase/tutorial/essential/concurrency/executors.html

Answer 2

它之后用在书中多次在多个线程中运行测试功能。它本身没有说明任何东西，但是它用来演示锁定，承诺以及其他并行和并发的东西。

Answer 3

dotimes，dothreads!和println不是纯函数：它们用于引入副作用。例如，

user=> (println 3) 
3 
nil 

该代码片段在屏幕上打印3，但返回nil。同样，dothreads!对其副作用而非其返回值很有用。