如何记忆一个使用Core.Async和非阻塞通道读取的函数？

Question

对于使用core.async和<！的函数，我希望使用memoize。例如

(defn foo [x]
  (go
    (<! (timeout 2000))
    (* 2 x)))

（在现实生活中，为了缓存服务器调用的结果，它可能很有用）

我可以通过编写memoize的core.async版本（与memoize几乎相同的代码）来实现这一点：

(defn memoize-async [f]
  (let [mem (atom {})]
    (fn [& args]
      (go
        (if-let [e (find @mem args)]
          (val e)
         (let [ret (<! (apply f args))]; this line differs from memoize [ret (apply f args)]
            (swap! mem assoc args ret)
            ret))))))

(def foo-memo (memoize-async foo))
(go (println (<! (foo-memo 3)))); delay because of (<! (timeout 2000))

(go (println (<! (foo-memo 3)))); subsequent calls are memoized => no delay

**备注：我需要一个与<！兼容的解决方案。有关<！！，请参阅以下问题：如何记忆使用core.async和阻塞通道读取的函数？**

Answer 1

您可以为此使用内置的memoize函数。首先定义一个从通道读取并返回值的方法：

 (defn wait-for [ch]
      (<!! ch))

注意，我们将使用<！！，而不是<！，因为在所有情况下，我们都需要这个功能块，直到通道上有数据为止。<！仅在go块内部的窗体中使用时才显示此行为。

然后，您可以通过使用foo组合这个函数来构造您的memoized函数，如下所示：

(def foo-memo (memoize (comp wait-for foo)))

(go (println (foo-memo 3))