3

我在使用 std::future 和 std::async 返回 std::vector 时遇到问题。为什么

#include <iostream>
#include <vector>
#include <functional>
#include <future>

using namespace std;

int main(int argc, char** argv) {

  int A = 10;
  vector<future<int>> sumarray(A);

  for(int i = 0; i < A; i++) 
    sumarray[i] = async( launch::async, [i] { return i; } );

  for(int i = 0; i < A; i++) 
    cout << sumarray[i].get() << " "; 
  cout << endl;

}

用 g++ -std=c++11 -pthread 编译按预期打印

0 1 2 3 4 5 6 7 8 9

但

#include <iostream>
#include <vector>
#include <functional>
#include <future>

using namespace std;

int main(int argc, char** argv) {

  int A = 10;
  int B = 2;
  vector<future<vector<int>>> sumarray(A);

  for(int i = 0; i < A; i++){
    sumarray[i] = async( launch::async, [i,B] { 
        vector<int> v(B);
        for(int j = 0; j < B; j++) v[j] = (j+1)*i;
        return v;
      }); 
  }

  for(int j = 0; j < B; j++)
    for(int i = 0; i < A; i++) 
      cout << sumarray[i].get()[j] << " "; 
  cout << endl;

}

以同样的方式编译 throw

terminate called after throwing an instance of 'std::future_error'
  what():  No associated state

我用 std::async 在 lambda 函数中返回向量的方式有问题吗？

4

2 回答 2

5

您get()多次调用sumarray. 根据文档：

调用此方法后，valid() 为 false。

这意味着您不能get()像内部循环那样多次调用。

于 2013-11-05T02:27:19.800 回答
1

以下代码有效。注释掉的行是问题所在。正如 JaredC 所说，问题在于在内部循环中使用 get() 。此外，从内存中为每个元素获取整个向量的效率也非常低，但这对我来说只是不好的做法。y_futures 是双精度的未来向量的向量。

 for (size_t i = 0; i < parts; ++i) {
    std::vector<double> temp = y_futures[i].get();
    for (size_t j = 0; j < num_rows_; ++j) {
      // y(j) = y_futures[i].get()[j];
      y(j) += temp[j];
    }
  }    ````
于 2020-05-25T21:58:52.857 回答