9

使用 Qt，我试图以非阻塞方式读取标准输入流的内容。当套接字收到一些新数据时，我正在使用 QSocketNotifier 来提醒我。通知程序的设置如下所示：

QSocketNotifier *pNot = new QSocketNotifier(STDIN_FILENO, QSocketNotifier::Read, this);
connect(pNot, SIGNAL(activated(int)), this, SLOT(onData()));
pNot->setEnabled(true);

onData()插槽如下所示：

void CIPCListener::onData()
{
    qDebug() << Q_FUNC_INFO;
    QTextStream stream(stdin, QIODevice::ReadOnly);

    QString str;

    forever
    {
        fd_set stdinfd;
        FD_ZERO( &stdinfd );
        FD_SET( STDIN_FILENO, &stdinfd );
        struct timeval tv;
        tv.tv_sec = 0;
        tv.tv_usec = 0;
        int ready = select( 1, &stdinfd, NULL, NULL, &tv );
        if( ready > 0 )
        {
            str += stream.readLine();
        }
        else
        {
            break;
        }
    }

    qDebug() << "Recieved data:" << str;
}

如您所见，我正在尝试使用 select() 系统调用来告诉我何时用完了要读取的数据。然而，实际上发生的事情是在我阅读了第一行文本后，select() 调用返回 0。因此，例如，如果我将 5 行文本写入进程的标准输入流，我只会读取第一行。

可能是什么问题呢？

4

2 回答 2

4

行缓冲。

默认是在“\n”之后刷新。如果您在进程中写入 5 行，您的插槽将被调用 5 次。如果你想避免这种情况，你必须调用 setbuf(stdin, _IOFBF)。但即便如此，也不能保证您可以在一个块中读取任意大量数据。

编辑：最好使用 QTextStream::atEnd() 而不是选择，因为 QTextStream 有自己的内部缓冲区。

于 2009-08-13T15:29:41.100 回答
1

我在其他答案中找到了几乎适合这个问题的示例，并且代码完整而简单：

https://stackoverflow.com/a/7389622/721929

我用它来实现一个基于 QT 控制台的应用程序，它带有一个文本菜单来选择用户选择。

于 2012-10-23T09:20:43.170 回答