如何使用 OpenMP 等待互斥体

Question

我有一个 for 循环，它将并行启动进程，每个启动的进程都会返回一个响应，表明它已准备好。我想等待响应，如果达到一定的超时时间，我将中止。

开发环境是VS2008
这是伪代码：

void executeCommands(std::vector<Command*> commands)
{
    #pragma omp parallel for
    for (int i = 0; i < commands.size(); i++)
    {
        Command* cmd = commands[i];
        DWORD pid = ProcessLauncher::launchProcess(cmd->getWorkingDirectory(),  cmd->getCommandToExcecute(), cmd->params);

        //Should I wait for process to become ready?
        if (cmd->getWaitStatusTimeout() > 0)
        {
            ProcessStatusManager::getInstance().addListener(*this);

            //TODO: emit process launching signal

            //BEGINNING OF QUESTION
            //I don't how to do this part. 
            //I might use QT's QWaitCondition but if there is another solution in omp
            //I'd like to use it
            bool timedOut;
            SOMEHANDLE handle = Openmp::waitWithTimeout(cmd->getWaitStatusTimeout(), &timedOut);
            mWaitConditions[pid]) = handle;
            //END OF QUESTION

            if (timedOut)
            {
                ProcessStatusManager::getInstance().removeListener(*this);
                //TODO: kill process
                //TODO: emit fail signal
            }
            else
            {
                //TODO: emit process ready signal
            }
        }
        else
        {
            //TODO: emit process ready signal
        }
    }
}

void onProcessReady(DWORD sourceProcessPid)
{
    ProcessStatusManager::getInstance().removeListener(*this);
    SOMEHANDLE handle = mWaitConditions[sourceProcessPid];
    if (mWaitConditions[sourceProcessPid] != 0)
    {
        Openmp::wakeAll(handle);
    }
}

Answer 1

正如上面的评论所指出的，Michael Suess 确实发表了一篇有关向 OpenMP 添加此功能的论文。他是最后一个提议向 OpenMP 添加某种类型的等待函数的人。 OpenMP 语言委员会已多次讨论该问题。每次它都被拒绝，因为已经有其他方法可以执行此功能。我不懂Qt，但是只要它提供的函数是线程安全的，那么你应该能够使用它们。