C++多线程程序问题：删除已join线程触发terminate()报错排查

首先，你的代码触发std::system_error的核心原因是在遍历vector<thread>的过程中修改容器，导致迭代器失效和悬空引用，进而引发未定义行为。下面具体拆解问题，并给出修复方案：

1. 直接导致错误的原因 #

（1）Range-based for循环的迭代器失效 #

你使用的for (thread &t : tids)是基于迭代器的遍历，当你调用erase删除容器中的元素时，当前迭代器及后续迭代器会直接失效。继续执行循环时，程序会访问无效的内存位置，这会触发各种未定义行为，包括你看到的std::system_error。

（2）erasePosition函数的逻辑缺陷 #

• 当你erase一个元素后，vector的后续元素会向前移动填补空缺，但你的循环变量i仍在递增，这会跳过下一个元素，导致部分线程无法被正确处理。
• 更严重的是：当你erase对应元素后，传入的thread &t会变成悬空引用（原线程对象已被销毁），后续操作可能会访问无效的线程对象，进一步加剧未定义行为。

2. 修复代码的核心思路 #

不要在遍历过程中直接通过引用操作元素，改用迭代器遍历，并利用erase的返回值（指向被删除元素的下一个有效迭代器）来维持遍历的有效性。同时可以简化逻辑，不需要单独的erasePosition函数。

修复后的代码示例：

vector<thread> tids;
const int nw = atoi(argv[1]); // number of worker

// 初始化线程
for (int i = 0; i < nw; i++) {
    tids.push_back(thread(solveSubTree, ref(works[i]), ref(nw)));
}

// 遍历并处理已完成的线程
auto it = tids.begin();
while (it != tids.end()) {
    // 等待当前线程完成
    it->join();
    // 删除当前线程对象，erase返回下一个有效迭代器
    it = tids.erase(it);
    cout << " tids.size() = " << tids.size() << endl;
    
    // 这里可以添加新的任务线程（工作窃取逻辑）
    // tids.push_back(thread(newTask, ...));
}

3. 关于工作窃取调度的优化建议 #

你当前的实现其实是"一次性创建线程→等待完成→删除"，这并不是真正的工作窃取模式。工作窃取通常会让线程在完成当前任务后主动从全局/其他线程的任务队列中获取新任务，而不是频繁创建和销毁线程（线程创建销毁的开销很高）。

一个更高效的工作窃取思路：

• 维护一个线程安全的任务队列。
• 初始化固定数量的工作线程（比如等于CPU核心数），每个线程循环从队列中取任务执行，直到队列为空且没有新任务加入。
• 当有新任务加入队列时，空闲的线程会自动获取并执行，实现动态的任务调度。

这种方式避免了频繁创建销毁线程的开销，也更符合工作窃取的设计思想。

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