c++ - std::future 或 std::shared_future 等待多线程

Question

我有一个线程从容器中获取每个元素并向数据库发送上传请求。上传是同步完成的。

容器中的元素是金融合约，它们可能有也可能没有与之关联的数据结构调用 ticktable。

现在，对于那些有 ticktable 的合约，我必须进行两次上传。 1)首先将ticktable上传到db。 db 返回一个 id。2) 将id附加到契约(Contract)上，然后上传契约(Contract)。

因此，例如，如果我循环遍历包含 100 个合约的容器，假设其中 30 个具有 ticktable，其余 70 个没有。

我想弄清楚 std::future 或 std::shared_future 是否适合这样的任务？

我尝试通过将 future 与 30 个合约中的每一个相关联并使用 launch:async 策略调用 std::async 来实现。因此，在循环的第一遍中，启动了 3o 个线程，并将返回的 future “移动”到与合约关联的容器中。其他 70 份契约(Contract)只是以通常的方式上传。

在第二遍中，我希望对存储的 future 调用get()。如果请求完成，获取id并用它完成合约上传。这可能行不通，因为我认为将 future 转移到容器会分离线程。

请问我应该采用哪种方法来实现我想要的行为？

Answer 1

移动 future 会导致其状态移动到目标。所以不，你没有你认为的问题。

您的 ticktable 解决方案看起来像是 future 的 future ——一种 future 用于 ticktable 上传，一种用于契约(Contract)上传。但从某种意义上说， future 的 future 就是 future 。

因此，一种方法是将 future 的 future 折叠成 future 。

假设您有一个契约(Contract)类型 Contract (我假设它是一个伪规则类型)。绑定(bind)你的 ticktable id 是一个 function<void(Contract&)> 类型的操作.有趣的是，这样的操作也可以是 noop。

所以有一个std::future<void(Contract&)> Contract::PrepareForUpload() const .对于您要上传的每份契约(Contract)，请上传。

有一个 ticktable 的返回一个 std::async生成 future拥有一个线程。

那些没有 ticktable 的返回一个延迟的 std::async包含一个 noop []{return [](auto&&...){};}工厂。

接下来，添加 std::future<void> Contract::Upload(std::function<void(Contract&>) const ，它会运行准备代码然后进行上传(为什么要在此处执行此操作？我稍后会展示)。

现在上传的操作是:

auto prep = contract.PrepareForUpload();
auto upload = contract.Upload(prep.get());

现在这有点烦人。做两件事？恶心。

为什么不为我们做呢？

std::future<void> Contract::Upload() const {
  return std::async(
    std::launch::async,
    [this]{
      auto prep = contract.PrepareForUpload();
      return contract.Upload(prep.get());
    }
  );
}

现在Contract::Upload自动为您准备和上传。

然而，这会在 ticktable 情况下启动 2 个线程。所以写一个同步PrepareForUpload可以在“组合”中调用 Upload案例。

如果PrepareForUpload需要额外的参数，我们可以将它们传递给 Upload .

可能有一些您没有涉及的细节可能会使这个过程变得更复杂，但是对 future 链的正确答案通常是将链条折叠成一个 future 。

C++1z 有关于 .then 的建议和类似的功能，以使这种链崩溃变得简单和高效。