c++ - 线程池的 lambda 函数内部的编译器错误变量 "Not captured"

Question

我正在学习 C++ 中的多线程并尝试设置线程池，但我收到一个编译器错误，提示“错误:‘mapperNodes’未被捕获”和“错误:‘command’未被捕获”。我读过一些关于使用“this”来捕获 lambda 中的变量的内容，但到目前为止没有任何效果。

如何在下面的代码中使用线程池 lambda 函数中的 command 和 mapperNodes 变量？

void MapReduceServer::spawnMappers() throw() {
  vector<string> mapperNodes(nodes);
  random_shuffle(mapperNodes.begin(), mapperNodes.end());
  string command = buildCommand(mapperNodes[0], executablePath, mapperExecutable, mapOutputPath);

  ThreadPool pool(numMappers);//numMappers = 8

  for (size_t id = 0; id < numMappers; id++) {
    pool.schedule([id] {
      cout << oslock << "Thread (ID: " << id << ") has started." << endl << osunlock;

      spawnWorker(mapperNodes[0], command); /*compiler error here*/

      cout << oslock << "Thread (ID: " << id << ") has finished." << endl << osunlock;
  });
}

Answer 1

当您编写 pool.schedule([id]{/*...*/}); 时，您告诉编译器您的 lambda 只需要 id 变量的值，仅此而已。

要使 MapReduceServer::spawnMappers() 的所有变量(拷贝)可用于 lambda，您可以更改 [id] 为 [= ]。