如何从 C++11 中的 std::future 移动结果?
How to move a result from an std::future in C++11?
我想在我的程序中异步处理 std::vector<int>
。然而,对象的检索不使用移动语义。
我创建了一个最小的工作示例并将其附加在下面。根据 cplusplus.com,复制和构造向量的移动语义在移动对象的大小上是线性的,在移动对象的大小上是常量,只要它们共享相同的分配器(我是使用标准的)。
再次根据 cplusplus.com,当从 std::future<T>::get()
和 T
中检索对象既不是 void
也不是引用类型(事实并非如此)时,它的行为就像移动值.
我什至尝试在第二个循环中只使用 inputs[i].get();
,目前在评论中,而不是将其分配给任何东西。这仍然会增加线性时间。
std::vector<std::vector<int>> GenerateTestCases(int input_size, int number_inputs) {
std::vector<std::vector<int>> cases(number_inputs);
for (auto i = 0; i < number_inputs; i++) {
std::vector<int> some_vector(input_size);
cases[i] = std::move(some_vector);
}
return std::move(cases);
}
int main() {
for (auto i = 0; i < 25; i++) {
auto size = (int)pow(2, i);
int iterations = 100;
auto test_cases = GenerateTestCases(size, iterations);
std::vector<std::future<std::vector<int>>> inputs(iterations);
const auto start = std::chrono::high_resolution_clock::now();
for (auto i = 0; i < test_cases.size(); i++) {
std::promise<std::vector<int>> prom;
prom.set_value(std::move(test_cases[i]));
inputs[i] = std::move(prom.get_future());
}
const auto middle = std::chrono::high_resolution_clock::now();
for (auto i = 0; i < test_cases.size(); i++) {
//inputs[i].get();
auto& result = (inputs[i]);
auto value = std::move(result.get());
}
const auto end = std::chrono::high_resolution_clock::now();
const auto elapsed_first = std::chrono::duration_cast<std::chrono::nanoseconds>
(middle - start).count();
const auto elapsed_second = std::chrono::duration_cast<std::chrono::nanoseconds>
(end - middle).count();
std::cout << "First: " << elapsed_first << std::endl;
std::cout << "Second: " << elapsed_second << std::endl;
std::cout << std::endl;
}
char c;
std::cin >> c;
}
但是,当我执行上面的代码时,我发现执行时间呈线性增加,范围从
First: 13440ns Second: 9919ns
对于最小的数组大小为
First: 25919ns Second: 300147450ns
最大的一个。
我在 Win10 上使用 VS2019 并为 x64 编译,如果这是出于兴趣。
时间成本可能来自于向量的破坏。
我做了一个测试,当结果保存在另一个向量中时,时间不会增加(即防止破坏)
http://coliru.stacked-crooked.com/a/dc7792496a981de3
而在您的原始代码中,时间确实增加了
我想在我的程序中异步处理 std::vector<int>
。然而,对象的检索不使用移动语义。
我创建了一个最小的工作示例并将其附加在下面。根据 cplusplus.com,复制和构造向量的移动语义在移动对象的大小上是线性的,在移动对象的大小上是常量,只要它们共享相同的分配器(我是使用标准的)。
再次根据 cplusplus.com,当从 std::future<T>::get()
和 T
中检索对象既不是 void
也不是引用类型(事实并非如此)时,它的行为就像移动值.
我什至尝试在第二个循环中只使用 inputs[i].get();
,目前在评论中,而不是将其分配给任何东西。这仍然会增加线性时间。
std::vector<std::vector<int>> GenerateTestCases(int input_size, int number_inputs) {
std::vector<std::vector<int>> cases(number_inputs);
for (auto i = 0; i < number_inputs; i++) {
std::vector<int> some_vector(input_size);
cases[i] = std::move(some_vector);
}
return std::move(cases);
}
int main() {
for (auto i = 0; i < 25; i++) {
auto size = (int)pow(2, i);
int iterations = 100;
auto test_cases = GenerateTestCases(size, iterations);
std::vector<std::future<std::vector<int>>> inputs(iterations);
const auto start = std::chrono::high_resolution_clock::now();
for (auto i = 0; i < test_cases.size(); i++) {
std::promise<std::vector<int>> prom;
prom.set_value(std::move(test_cases[i]));
inputs[i] = std::move(prom.get_future());
}
const auto middle = std::chrono::high_resolution_clock::now();
for (auto i = 0; i < test_cases.size(); i++) {
//inputs[i].get();
auto& result = (inputs[i]);
auto value = std::move(result.get());
}
const auto end = std::chrono::high_resolution_clock::now();
const auto elapsed_first = std::chrono::duration_cast<std::chrono::nanoseconds>
(middle - start).count();
const auto elapsed_second = std::chrono::duration_cast<std::chrono::nanoseconds>
(end - middle).count();
std::cout << "First: " << elapsed_first << std::endl;
std::cout << "Second: " << elapsed_second << std::endl;
std::cout << std::endl;
}
char c;
std::cin >> c;
}
但是,当我执行上面的代码时,我发现执行时间呈线性增加,范围从
First: 13440ns Second: 9919ns
对于最小的数组大小为
First: 25919ns Second: 300147450ns
最大的一个。
我在 Win10 上使用 VS2019 并为 x64 编译,如果这是出于兴趣。
时间成本可能来自于向量的破坏。
我做了一个测试,当结果保存在另一个向量中时,时间不会增加(即防止破坏)
http://coliru.stacked-crooked.com/a/dc7792496a981de3
而在您的原始代码中,时间确实增加了