c++ - Qt Thread 在 Linux 中进行 ping 操作

Question

我正在尝试完成看似非常简单的任务...但它却是一场噩梦。

我为 Linux 笔记本电脑开发了一个应用程序。在应用程序内部，我希望有一个独立的线程，可以连续 ping 另一台 PC(例如，每 5 秒一次，永远......好吧，只要笔记本电脑打开)。

当然，当应用程序正在 ping 的 PC 未连接时，应用程序必须顺利工作，而无需等待 ping 操作返回...我该如何实现这一点？

起初，我使用了 QTimer 和 QProcess:execute("ping"...)，效果很好。问题是，如果另一台电脑没有回复，我的整个应用程序及其 GUI 在每次 ping 操作时都会卡住大约一秒钟。更改“ping”选项(例如设置“-i0.2”)以减少 ping 操作的等待时间，但没有帮助:当另一台 PC 未连接时，我的应用程序变得非常慢。如果我删除 ping，当然一切都会顺利进行。

因此，我决定在 QThread 中插入“ping”操作，但是当我尝试遵循 http://doc.qt.io/qt-4.8/qthread.html 中的第二个示例时，似乎没有任何效果:应用程序甚至无法启动。

代码如下:

//Pinger.h
class Pinger : public QThread
{
Q_OBJECT  
 void run();
public:
    void setParam(const QString &urlToPing); // it sets the url to ping

signals:
    /// \brief  Signal emitted when pinging of specified url fails
    void pingFailed(int ok);
private:
    QString pingurl;
};

//Pinger.cpp
void Pinger::run()
{
    int exitCode;
    QProcess pingProc;
    while(true)
    {
        exitCode=pingProc.execute("ping",QStringList() << "-c 1" << "-i0.2" << pingurl);
        emit pingFailed(exitCode);
        sleep(5);
    }
}

// MainWindow::MainWindow
        pinga= new Pinger(); // defined in mainwindow.h as Pinger* Pinga
        pinga->setParam(ip_address);
        connect(pinga,SIGNAL(pingFailed(int)),this,SLOT(connectionLost(int)));
        connect(pinga,SIGNAL(finished()),pinga,SLOT(deleteLater()));
        pinga->start();

有人尝试过类似的方法吗？我对 Qt 还很陌生，但是这个操作看起来是如此微不足道，以至于我觉得不可思议的是没有明确的方法来实现它。所以我希望我只是错过了一些明显的东西。

Answer 1

如果使用QThread，最好避免sleep(5);和循环while(true)，因为线程不能优雅地关闭而不杀死它。与其循环和阻塞 sleep ，不如通过在前一个任务(进程执行)完成时启动的单次定时器再次调用该周期性任务。但是，在这种情况下，该逻辑应该在其他一些成员槽中实现 (Pinger::doWork())。槽 run() 应保留其执行 Tread 事件循环的默认实现。可以通过将 QThread::started() 信号与 Pinger::doWork() 连接来启动工作:

connect(pinga, SIGNAL(started()), pinga, SLOT(doWork()));

---

删除QThread需要小心。一般来说，单独删除QThread对象(从其finished()信号中调用deleteLater())是不好的。最好停止线程并在 MainWindow 析构函数中将其删除:

MainWindow::~MainWindow
{
    // stop the even loop
    pinga->quit();
    // wait for finishing current thread task; it can work only
    // if the thread is not blocked by while(true) with sleep
    pinga->wait();
    // delete if it is not a smart pointer
    delete pinga;
 }

---

也可以在主 GUI 线程中使用 QProcess 及其非阻塞 API，而无需 QThread。在这种情况下，它应该由 QProcess::start() 启动，并且插槽连接到信号 QProcess::error() 和 QProcess::finished( ) 应该用于开始下一次迭代。这些槽也不应该阻塞主线程，因此在上一个 ping 完成后，应该使用 QTimer 启动下一个 ping。