C++Builder中无法等待所有任务完成问题求助

核心问题 #

1. 数组越界访问：每次外层循环创建的ThreadList数组长度为ThreadCount，但赋值时用了ThreadList[i + j]，当i不为0时（比如第二次循环），i+j会超出数组索引范围（数组索引应为0~ThreadCount-1），引发内存错误进而导致程序挂起。
2. 死锁风险：主线程调用TTask::WaitForAll()阻塞等待子线程完成，但子线程里的TThread::Synchronize()需要主线程处理消息循环才能执行回调，此时主线程被阻塞无法处理消息，子线程的回调无法完成，最终形成互相等待的死锁。
3. WaitForAll参数冗余计算：(sizeof(ThreadList[0]) * ThreadCount) / sizeof(ThreadList[0]) - 1等价于ThreadCount-1，冗余计算毫无必要。

修正后的代码 #

PartsToTranslateCount = PartsToTranslate.size();
_di_ITask* ThreadList;
    
for (int i = 0; i < PartsToTranslateCount; i += nbMaxThreads->Value) {
    ThreadCount = System::Math::Min(int(nbMaxThreads->Value), int(PartsToTranslateCount - i));
    ThreadList  = new _di_ITask[ThreadCount];
    memoTranslatedText->Lines->Add("cicle #-" + IntToStr(i));
    for (int j = 0; j < ThreadCount; j++) {
        // 修正数组索引：用j而非i+j，适配当前批次数组的长度范围
        ThreadList[j] = TTask::Create([this, i, j]() {
            // 用Queue替代Synchronize，避免主线程阻塞时无法处理回调导致死锁
            TThread::Queue(nullptr, _di_TThreadProcedure([this, i, j] {
                Application->ProcessMessages();
                this->memoTranslatedText->Lines->Add(IntToStr(i + j));
            }));
        });
        ThreadList[j]->Start();
    }
    // 直接使用ThreadCount-1作为数组最后一个元素的索引
    TTask::WaitForAll(ThreadList, ThreadCount - 1);
    delete[] ThreadList;
}
memoTranslatedText->Lines->Add("Done");

关键修改说明 #

• 修复数组索引：将ThreadList[i + j]改为ThreadList[j]，确保始终在当前数组的合法索引范围内访问元素，避免内存越界。
• 替换同步方式：用TThread::Queue()替代Synchronize()，回调会被放入主线程消息队列，主线程空闲时自动处理，不会阻塞子线程，解决死锁问题。
• 简化参数传递：直接使用ThreadCount - 1作为WaitForAll的第二个参数，逻辑清晰且避免计算错误。

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