等待多个未来？

Question

我想运行相同类型的任务（工作线程），但一次不超过一定数量的任务。当任务完成时，其结果是新任务的输入，然后可以启动该任务。

有没有好的方法可以在C 11中使用异步/未来范式来实现这一点？

乍一看，它看起来很简单，你只是生成多个任务：

std::future<T> result = std::async(...);

然后，运行result.get（）以获取任务的异步结果。

然而，这里的问题是，未来的对象必须存储在某种队列中并一个接一个地等待。但是，可以一遍又一遍地迭代未来的对象，检查它们中的任何一个是否准备好了，但是由于不必要的CPU负载，这是不需要的。

是否有可能以某种方式等待一个给定集合中的任何未来准备好并得到它的结果？

到目前为止，我能想到的唯一选择是没有任何异步/未来的老式方法。具体而言，生成多个工作线程，并在每个线程结束时将其结果推入受互斥锁保护的队列，通过条件变量通知等待的线程队列已更新更多结果。

有没有其他更好的异步/未来解决方案？

Answer 1

Facebook的愚蠢已经收集了所有的期货，我还没有尝试过，但看起来很有希望。

Answer 2

你可以创建“第一代”的所有未来，并将所有这些未来交给你的第二代任务，然后他们将自己等待他们的输入。

Answer 3

C 11中的线程支持只是第一次，虽然std::future很重要，但它还不支持多次等待。

然而，你可以相对低效地伪造它。您最终为每个＜code＞std：：future＜/code＞（哎哟，非常昂贵）创建了一个助手线程，然后将它们的“this＜code＞future

此系统中的 std：：future 不会添加太多功能，并且让任务直接声明它们已准备就绪并将其结果粘贴到上述队列中会更有效。如果采用此路由，则可以编写与 std：：async 或 std：：thread 模式匹配的包装器，并返回表示队列消息的 std：：future 类似对象。这基本上涉及重新实现并发库的一部分。

如果您想继续使用std::future，您可以创建shared_futures，并让每个依赖任务依赖于shared_futures的集合：即在没有中央调度程序的情况下进行。这不允许像中止/关闭消息这样的事情，我认为这对于健壮的多线程任务系统至关重要。

最后，您可以等待C 2x，或者每当并发TS被合并到标准中时，为您解决问题。