在线程内启动 QProcess

Question

我已经为这个基本问题苦苦挣扎了一段时间。 我正在尝试从一个线程开始一个QProcess。启动进程工作正常，进程正常运行，但我的问题是永远不会发出 finished() 信号。

这是我的例子：

我的类变量是

std::atomic<bool>  recording;
QProcess proc;
std::unique_ptr<std::thread> recordingThread;

班级：

Recorder::Recorder(ParentClass *parent): QObject(parent){

    connect(&proc,SIGNAL(finished(int)),this,SLOT(finishedFFMPEG())); 
}

void Recorder::start(){

    if (!recordingThread){
        recording = true;
        recordingThread.reset(new std::thread(&Recorder::recordThread, this));
    }
}

void Recorder::recordThread(){

    while(recording){
        //writing frame
    }
    proc.start("C:\\ffmpeg.exe", QStringList() <<"-i"<< picDir.c_str() << "-r"<< "30" << "-vcodec"<< "ffv1" << filename.c_str());
    proc.waitForStarted();      
}

void Recorder::stop(){

    if (recordingThread) {
        recording = false;
        recordingThread->join(); recordingThread.reset();  
    }
}

void Recorder::finishedFFMPEG(){
    qDebug() << "finished";
}

start() 和 stop() 是从我的 ParentClass 中的另一个非 GUI 线程调用的。

我尝试了一切，从使用指针、将recordThread() 作为QThread 运行并在stop() 函数中启动QProcess，但我根本没有收到来自进程的finished() 信号。该过程本身正在正确执行。我知道问题在于不同的事件循环。

如何实现在recordThread() 完成后启动进程并捕获QProcess finished() 信号的目标？

Answer 1

我不能说我很惊讶你的构造不起作用。您在不同的线程中使用 std::thread 执行成员函数 recordThread()。到现在为止还挺好。在 recordThread() 你有一个循环，看起来它收集/创建/写入帧。一旦离开循环，帧就会通过 QProcess 传递给 ffmpeg。至少这是你的意图。我做对了吗？

现在，在 stop() 中清除记录标志，这会导致 while 循环结束。 QProcess 启动。但与此同时，您结束了该 QProcess 所在的 recordThread() 线程。而且您希望不仅 QProcess 能够幸存下来，它可能会这样做，而且所有信号/插槽连接都保持完好？

我不完全知道 QProcess 会发生什么、可能的竞争、阻塞/非阻塞效应，但我敢打赌你的问题正是在这个领域。

还有一件事……我认为在线程 A 中创建 QProcess 并不健康，但像你一样在线程 B 中启动它。

我会尝试这样的事情（未经测试）：

while(recording){
 //writing frame
}
QProcess p;
connect(&p,SIGNAL(finished(int)),this,SLOT(finishedFFMPEG()));
p.start(...your ffmpeg stuff...);
p.waitForFinished(-1);

在finishedFFMPEG()中

recordingThread->join(); recordingThread.reset();

然后线程被杀死，当 QProcess 完成时。