我可以在 clojure.core.async/go 中取消期货/承诺吗？

Question

我试图找到一种方法来无害地观察许多futures。我的意思是不阻塞 N 个线程来等待 N 个 futures。

我看到core.async 库的构建方式不会通过阻塞操作阻塞线程，而是将其停放并重用线程。是 deref 的情况，还是仅适用于 <! 和 alts!？

Answer 1

future-done? 函数可用于轮询一组期货以查看哪些期货可供查看：

main> (future-done? (future 42))
true
main> (future-done? (future (Thread/sleep 1000) 42))
false

然后您可以创建一个函数来轮询所有期货（也许在一个向量中）以供其处理，然后继续执行该工作。这种方式不是在 each 未来阻塞一个线程，而是在 any 未来阻塞一个线程并决定你想要多少这样的工人（一次一个是常见的选择）

如果您希望它比这更高效或更具表现力，您将创建一个状态机来跟踪要检查和处理哪些未来，这将使您走上重新创建自己的版本clojure.core.async/alts! 和一直使用 core.async 可能会更好。