生成线程时的 boost::thread 运行时错误

Question

我有一个项目，我们希望提供使用线程来加速一切。 我们希望能够在单独的线程中调用这个函数：

Request& Filter::processRequest(Request& req)

因此我将函数打包在 lambda 表达式中以访问返回值。

我现在收到以下运行时错误：

  glibc detected ... double free or corruption (!prev): ...

当我取消注释将线程添加到组的行时，一切正常。

boost::thread_group thread;
for (std::set<boost::shared_ptr<Filter> >::iterator i = sources_.begin();
    i != sources_.end(); ++i) {
         Request ret
         thread.add_thread(new boost::thread(boost::lambda::var(ret) = 
            (*i)->processRequest(req)));
         req+=ret;
         ...
}
thread.join_all();

此运行时错误的原因可能是什么。或者有没有另一种方法可以把这个函数放在单独的线程中？

Answer 1

如果这种技术完全有效，您将需要多个可以稳定引用的 ret 值（每个执行线程一个）。而且您必须等到线程连接完成后才能使用这些值。

您可以尝试的一个简单修改就是在vector<Request> retValues...的循环之外创建一个向量，然后在每次add_thread 时向向量添加一个元素并传递对该元素的引用。那么如果你等到加入之后才使用这些值，也许它会起作用？

boost::thread_group thread;
vector<Request> retValues;
for (std::set<boost::shared_ptr<Filter> >::iterator i = sources_.begin();
    i != sources_.end(); ++i) {
         retValues.push_back(0);
         thread.add_thread(new boost::thread(
            boost::lambda::var(retValues.back()) = 
            (*i)->processRequest(req)));
         ...
}
thread.join_all();
// retValues safe to use here...

（注意：可能不需要使用boost::lambda；您可以使用 boost::bind 连接到存储结果的工作类：

Getting return value from a boost::threaded member function?

...但实际上，无论您需要什么，每个线程都需要一个单独的变量来存储结果...其生命周期的持续时间足以让线程能够对其进行写入。）