- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我有一个线程从容器中获取每个元素并向数据库发送上传请求。上传是同步完成的。
容器中的元素是金融合约,它们可能有也可能没有与之关联的数据结构调用 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/
我正在尝试为 Raspberry Pi 交叉编译一个大型项目。我正在使用由 crosstool-ng 构建的工具链,gcc 版本 4.7.3。当看到 std::shared_future 时,编译会停
Passing std::shared_future by value是合法的,因为 std::shared_future 是可复制的。 #include #include #include i
我找不到关于此事的直接确认或反驳。所有答案似乎都解决了“从多线程访问”方面的问题,而不是重复访问本身。 标准是否定义了 std::shared_future 的行为? boost::shared_fu
future 和 shared_future 有什么区别? 在什么情况下我们必须使用 shared_future 而不是 future? 我试图找到可以对比 C++11 的这两个特性的好的文档,但我在
一般问题: 是 std::shared_future::operator= atomic 吗? 例如 struct object { object() { sf = std::
我有一个 DAG 任务,我正在尝试使用 boost::shared_future 框架执行这些任务。 举个具体的例子,考虑图中的data flow graph。 下面是对此进行编码的尝试: #incl
Josuttis 指出 [“标准库”,第 2 版,第 1003 页]: Futures allow you to block until data by another thread is provi
我有一个线程从容器中获取每个元素并向数据库发送上传请求。上传是同步完成的。 容器中的元素是金融合约,它们可能有也可能没有与之关联的数据结构调用 ticktable。 现在,对于那些有 ticktabl
我对 Effective Modern C++ 的第 270 页有疑问,作者是 Scott Meyers。 第 5/6 行,他写道:“唯一的微妙之处在于每个 react 线程都需要引用共享状态的 st
我了解什么是 std::future 但我不了解何时以及如何使用 std::shared_future 和 std::promise,而且我在网上找不到很好的解释。 我会很感激一些帮助我解决这个问题。
C++标准库中的各种类都有成员交换函数,包括一些多态类,如std::basic_ios。 .模板类std::shared_future显然是一个值类型并且 std::future是一个只能移动的值类型
我尝试使用 boost thread futures .所以如图here我们可以得到 shared future来自 packaged task . 所以我在 linux 上尝试这样的功能: temp
我是一名优秀的程序员,十分优秀!