QProcess: казнить блокирует все приложение

Question

В моем приложении я использую следующий код для создания новых потоков и выполнить внешнее приложение в этих потоках:

int main(int argc, char *argv[]) 
{ 
... 
    WebSocketServer *server = new WebSocketServer(); 
    QObject::connect(server, &WebSocketServer::closed, &a, &QCoreApplication::quit); 
    QObject::connect(server, SIGNAL(messageReceived(QJsonObject)), dm, SIGNAL(sendHandleProcessedFiles(QJsonObject))); 
    QObject::connect(dm,SIGNAL(sendServerNotify(int, QByteArray)),server,SLOT(notifySender(int, QByteArray))); 
} 

void WebSocketServer::processTextMessage(QString message) 
{ 
    QThread* workerThread = new QThread(); 
    Task *task = Task::createTask(Id); 
    task->moveToThread(workerThread); 

    QObject::connect(task, SIGNAL(workFinished()), workerThread, SLOT(quit())); 
    QObject::connect(workerThread, SIGNAL(finished()), task, SLOT(deleteLater())); 
    QObject::connect(workerThread, SIGNAL(finished()), workerThread, SLOT(deleteLater())); 
    workerThread->start(); 
    task->execute(); 
} 


void Task::execute() 
{ 
    ... 
    //Execute external program 
    QProcess process; 
    process->start(cmd); 
    process->waitForFinished(-1); 
    //Execution should continue after termination of external program within the thread created in WebSocketServer::processTextMessage 
    ... 
} 

Внутри моего объекта задачи я должен выполнить внешнюю программу, подождите пока его выполнение не завершится и не продолжит мой программный код. Я хочу, чтобы мой поток ожидал, пока выполнение программы не завершится, поэтому не нужен асинхронный механизм.

Проблема заключается в том, что не только отдельный поток ожидает программу, но и все приложение блокируется до тех пор, пока программа не завершится. Таким образом, все запросы, которые я получаю, например, для моего сервера websocket, блокируются.

Я ожидал, что процесс будет выполнен в потоке, откуда он вызывается, и не влияет на другие потоки. Есть идеи?

Answer 1

Насколько я понимаю ваш вопрос, ваша проблема здесь:

QThread* workerThread = new QThread(); 
Task *task = Task::createTask(Id); 
task->moveToThread(workerThread); 
... 
workerThread->start(); 
task->execute(); 

Здесь вы выполнения задачи в основном потоке не в этом потоке. Обратите внимание, что в moveToThread все слоты выполняются в новом потоке, а не в явных вызовах метода.

В вашем коде task->execute(); выполнен в основном потоке.