C++多线程问题：Worker函数未接收正确传入的订单簿数据

问题原因 #

你的代码核心问题出在lambda表达式的引用捕获机制上：

• 内部循环中，orderCache是每次迭代的局部指针变量，你用[&]捕获了它的引用。
• 线程创建后不会立即执行，当后续循环迭代时，orderCache会被重新赋值为下一个订单簿的指针，此时之前创建的线程里的lambda引用的orderCache已经指向了新的对象。
• 当线程最终执行时，拿到的是orderCache最后一次被赋值的结果，导致部分订单簿被重复处理，部分完全被跳过（因为线程还没执行，对应的orderCache已经被覆盖）。

另外，processOrderEntry采用值传递参数会导致整个OrderBook被拷贝，对于大数据量的订单簿来说，这会严重降低性能，甚至可能成为新的瓶颈。

修正方案 #

方案1：按值捕获指针，避免引用被覆盖 #

修改线程创建的lambda表达式，将orderCache按值捕获，这样每个lambda都会持有当前迭代的订单簿指针副本，不会被后续循环影响：

threadVector.emplace_back([orderCache]() { processOrderEntry(*orderCache); });

方案2：优化参数传递，避免不必要拷贝 #

将processOrderEntry的参数改为引用或指针传递，减少内存拷贝开销：

引用传递版本

// 修改函数定义为引用传递
void processOrderEntry(OrderBook<OrderBookEntry>& orderCache)
{
    std::cout << "Calc : " << orderCache.OrderBookID() << std::endl;
    // ... 处理逻辑
}

// 线程创建时按值捕获指针，传递引用
threadVector.emplace_back([orderCache]() { processOrderEntry(*orderCache); });

指针传递版本

// 修改函数定义为指针传递
void processOrderEntry(OrderBook<OrderBookEntry>* orderCache)
{
    std::cout << "Calc : " << orderCache->OrderBookID() << std::endl;
    // ... 处理逻辑
}

// 线程创建时按值捕获指针，直接传递
threadVector.emplace_back([orderCache]() { processOrderEntry(orderCache); });

额外优化建议 #

• 可以考虑使用std::async代替手动管理线程，或者用线程池（比如C++20的std::jthread）来更高效地管理线程资源，避免频繁创建销毁线程的开销。
• 如果订单簿数据在处理过程中可能被修改，需要添加互斥锁（std::mutex）保护共享数据，避免竞态条件。

内容的提问来源于stack exchange，提问作者NULseg