C++ 2011:std::thread:并行化循环的简单示例？

Question

C++ 2011 包含非常酷的新功能，但我找不到很多并行化 for 循环的示例。 所以我非常幼稚的问题是:如何将简单的 for 循环(例如使用“omp parallel for”)与 std::thread 并行化？ (我搜索了一个例子)。

非常感谢。

Answer 1

std::thread 不一定意味着并行循环。它旨在作为构建类似 parallel_for 算法的结构的低级抽象。如果你想并行化你的循环，你应该自己编写一个 parallel_for 算法，或者使用提供基于任务的并行性的现有库。

以下示例展示了如何使简单循环并行化，但另一方面也展示了缺点，例如缺少负载平衡和简单循环的复杂性。

  typedef std::vector<int> container;
  typedef container::iterator iter;

  container v(100, 1);

  auto worker = [] (iter begin, iter end) {
    for(auto it = begin; it != end; ++it) {
      *it *= 2;
    }
  };


  // serial
  worker(std::begin(v), std::end(v));

  std::cout << std::accumulate(std::begin(v), std::end(v), 0) << std::endl; // 200

  // parallel
  std::vector<std::thread> threads(8);
  const int grainsize = v.size() / 8;

  auto work_iter = std::begin(v);
  for(auto it = std::begin(threads); it != std::end(threads) - 1; ++it) {
    *it = std::thread(worker, work_iter, work_iter + grainsize);
    work_iter += grainsize;
  }
  threads.back() = std::thread(worker, work_iter, std::end(v));

  for(auto&& i : threads) {
    i.join();
  }

  std::cout << std::accumulate(std::begin(v), std::end(v), 0) << std::endl; // 400

使用提供 parallel_for 模板的库，可以将其简化为

parallel_for(std::begin(v), std::end(v), worker);