3

我正在学习 Clojure 中的并发性。

我在http://dev.clojure.org/display/design/Scheduled+Events遇到了一个索赔（Stuart Serra？），声明：

  • Clojure 函数不能在没有阻塞或 Java 互操作的情况下将时间用于控制流
  • Java 互操作 (ScheduledThreadPoolExecutor) 不知道线程本地绑定

我不理解这些说法，请澄清一下，也许是一个例子。具体来说：

  • ScheduledThreadPoolExecutor 有什么问题？由于我正在启动一个新的（绿色）线程，因此我不希望每个线程的绑定能够继续。
  • 我可以安排一个普通的 Clojure 函数，那么是什么阻止我将所需的绑定作为词法封闭的上下文发送？

非常感谢！

4

1 回答 1

4

好的，我想我明白了。

假设你试试这个：

(def pool (atom nil))

(defn- thread-pool []
    (or @pool
        (reset! pool (ScheduledThreadPoolExecutor. 1))))

(def ^:dynamic *t* 0)

(binding [*t* 1]
    (future (println "first example:" *t*)))

(binding [*t* 1]
    (.schedule (thread-pool) (fn [] (println "second example:" *t*)) 0 
               TimeUnit/SECONDS))

(binding [*t* 1]
    (.schedule (thread-pool) (bound-fn [] (println "third example:" *t*)) 0
               TimeUnit/SECONDS))

输出将是：

first example: 1
second example: 0
third example: 1

在第一种情况下，future 宏用私有函数 binding-conveyor-fn 包装主体，它将调用线程的绑定框架保留在词法范围内，并在调用包装函数之前恢复它。

在第三种情况下，bound-fn 将调用线程的绑定推送到框架上，执行函数体，然后弹出绑定。

在第二种情况下，没有人保存每个线程的绑定——Java 类当然不知道它们，因此我们将其放到t Var 的根值。

我希望有人会觉得这很有趣。

于 2012-08-17T15:01:33.030 回答