这个问题困扰着我,因为它应该有效,但遗憾的是它没有。
我试图实现的是读取某个进程的标准输出并让另一个进程处理它,即打印出来。
产生输出的过程如下所示:
#include <stdio.h>
#include <stdlib.h>
#include <iostream>
int main() {
for (int i = 0; i < 100; i++) {
printf("yes %d\n",i);
fflush(stdout);
sleep(1);
}
return 0;
}
该过程在另一个应用程序中启动,如下所示:
#include <QProcess>
...
QProcess * process = new QProcess;
SomeClass * someClass = new SomeClass(process);
connect(process,SIGNAL(readyRead()),someClass,SLOT(onReadyRead()));
process->start("../Test/Test",QStringList());
if (!process->waitForStarted(4000)) {
qDebug() << "Process did not start.";
}
...
void SomeClass::onReadyRead() {
qDebug() << "Reading:" << process->readAllStdOutput();
}
我的预期输出是:
Reading: yes 0
Reading: yes 1
...
Reading: yes 99
但是我根本没有得到任何输出。
当我使用 QCoreApplication 时,我得到所有输出,但不是通过信号/槽,而是直接在控制台中。
我不明白,因为它可以在另一个使用 Qt 4.8 的应用程序中工作。
我的问题是,是否有人遇到同样的问题,或者有人知道我如何才能获得预期的行为?
您提供的答案中的问题在于误解了阅读的原理。它只是返回您在那里获得的任何数据,无论是否有行结尾。通过生成线程并在行之间休眠,您可以有效地以行大小的块发送进程间数据,因为当您等待足够长的时间时管道会被刷新。
所以,你在工作时的答案并不是真正应该如何做。你需要使用readLine()
将传入的数据切成行。下面是一个具有以下特性的示例:
- 只有一个可执行文件:)
- 仅使用 Qt api。这减少了运行时内存消耗。
- 两个进程都会干净地终止。
- 代码量尽可能少。
// https://github.com/KubaO/stackoverflown/tree/master/questions/process-17856897
#include <QtCore>
QTextStream out{stdout};
class Slave : public QObject {
QBasicTimer m_timer;
int m_iter = 0;
void timerEvent(QTimerEvent * ev) override {
if (ev->timerId() == m_timer.timerId()) {
out << "iteration " << m_iter++ << endl;
if (m_iter > 35) qApp->quit();
}
}
public:
Slave(QObject *parent = nullptr) : QObject(parent) {
m_timer.start(100, this);
}
};
class Master : public QObject {
Q_OBJECT
QProcess m_proc{this};
Q_SLOT void read() {
while (m_proc.canReadLine()) {
out << "read: " << m_proc.readLine();
out.flush(); // endl implicitly flushes, so we must do the same
}
}
Q_SLOT void started() {
out << "started" << endl;
}
Q_SLOT void finished() {
out << "finished" << endl;
qApp->quit();
}
public:
Master(QObject *parent = nullptr) : QObject(parent) {
connect(&m_proc, SIGNAL(readyRead()), SLOT(read()));
connect(&m_proc, SIGNAL(started()), SLOT(started()));
connect(&m_proc, SIGNAL(finished(int)), SLOT(finished()));
m_proc.start(qApp->applicationFilePath(), {"dummy"});
}
};
int main(int argc, char *argv[])
{
QCoreApplication app{argc, argv};
if (app.arguments().length() > 1)
new Slave{&app}; // called with an argument, this is the slave process
else
new Master{&app}; // no arguments, this is the master
return app.exec();
}
#include "main.moc"
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)