我有一个线程从容器中获取每个元素并向数据库发送上传请求。上传是同步完成的。
容器中的元素是金融合约,它们可能有也可能没有与之关联的数据结构调用 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 转移到容器会分离线程。
请问我应该采用哪种方法来实现我想要的行为?
最佳答案
移动 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
的建议和类似的功能,以使这种链崩溃变得简单和高效。
关于c++ - std::future 或 std::shared_future 等待多线程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37373564/