使用 akka future 和 actor 并行化列表
我想向参与者发送消息列表，在未来立即收到回复，然后等待所有未来完成，然后再返回调用方法。通过阅读 akka 文档，我相信 Future.sequence 是可行的…
future.get 在取消时最终在 Callable 中执行之前返回
我有一个测试间歇性失败，当 future 被取消时， future.get 调用在 Callable 中执行 finally 块之前返回。这是基本工作流程： future.cancel(true); …
如何创建带有参数的packaged_task？
遵循这个关于期货的优秀教程 /em>、承诺和打包任务我已经到了想要准备自己的任务的程度， #include #include using namespace std; int ackermann(int…
Akka / future——Akka 是否决定它是否“值得”？使用当前线程还是调度程序？
我目前正在考虑使用 Akka（Java API/库）来完成创建多个 Future 并将它们放入 BlockingQueue 的任务。现在，由 Callables 处理的某些任务可能在调用线…
C++，Linux：错误：从 ‘boost::unique_future’ 转换到非标量类型 ‘boost::shared_future’要求。如何绕过它？
我尝试使用 Boost 线程期货。如此处 我们可以得到共享未来 来自 打包任务。 所以我在linux上尝试这样的函数： template void pool_item( boost::share…
如何与actor实现异步相互依赖的可取消操作？
我对 Actor 模型还很陌生，这就是为什么我认为已经有既定的模式可以用 Actor 和 future 等美丽的可组合抽象来解决我的常见场景。 我的异步操作具有以…
计算 futures.ThreadPoolExecutor 中待处理任务的数量
我正在寻找一种计算 python 3.2 futures.ThreadPoolExecutor 中待处理任务数量的方法。 直到知道，我有两个解决方案： 1.- 增加提交时待处理任务的计…
如何正确使用线程池并从线程中获取结果？
我正在尝试尝试多线程编程（对我来说是新的），但我有一些问题。 我正在使用一个带有 TestTask 的 ThreadPoolTaskExecutor，该 TestTask 实现了 R…
如何使用 boost 线程 future 向量？
如何使用线程 future 向量从一组线程获取返回值？这应该有效吗？如果不是，我该如何适应？ int calculate_the_answer_to_life_the_universe_and_every…
将多个参数传递给concurrent.futures.Executor.map？
concurrent.futures.Executor.map 接受可变数量的可迭代对象，从中调用给定的函数。 如果我有一个生成器，可以生成通常在适当位置解包的元组，我应该…
处理两种不同类型的未来（其中一种未来依赖于另一种未来）的理想方式是什么？
我正在查看 AKKA 的 Java Futures API，我看到了很多处理同一类型的多个 future 的方法，但我没有看到任何处理不同类型的 future 的方法。我猜我让事…
如何反转 set_value() 和“停用”一个承诺？
我在这里有一个关于同步的问题。我有一个“编写者”线程，它在每次迭代时为承诺分配不同的值“p”。我需要“读取器”线程等待该值的shared_futures，…
