暂停 QThread

Question

UpdateThread is-a QThread 在 UpdateThread::run() 中设置一个调用 slot QTimer >UpdateThread::tick() 每 t 毫秒。现在，根据某些条件，我需要暂停线程，一段时间后，根据另一个条件，我需要唤醒它。

---

• 我做 QTimer 事情的方式可以吗？或者我应该将 tick 代码移动到 run 并每隔 t ms 调用 QThread::start() ？
• 如何有条件地暂停和唤醒线程
• 或者我应该只是 stop() QTimer 和 start() 后者？

Answer 1

首先，您不应该在 QThread 子类上定义插槽并从 run() 中调用它们 - 插槽将被执行（通过执行跨线程插槽调用）在拥有 UpdateThread 实例的线程上下文中（与创建该实例的线程相同，除非您对其调用 moveToThread() ），而不是在 UpdateThread 表示的线程上下文中。记住这个助记符：

在run()中，QThread::thread()!= this

相反，在您在 run() 中创建的 QObject 子类上定义插槽>。

好吧，抛开这个问题，让我们看一下计时器。 QTimer 文档包含以下内容：

在多线程应用程序中，您可以在任何具有事件循环的线程中使用QTimer。
要从非 GUI 线程启动事件循环，请使用 QThread::exec( ）。 Qt 使用定时器
线程亲和性来确定哪个线程将发出 timeout() 信号。
因此，您必须在其线程中启动和停止计时器；这是不可能的
从另一个线程启动计时器。

（强调我的）特别注意最后一句。

解决方案是跨线程调用 QTimer::start() 和 QTimer::stop()。您可能了解跨线程信号/槽连接。这使用相同的底层机制，该机制在 QMetaObject::invokeMethod( )：

class UpdateThread : public QThread {
    Q_OBJECT
private:
    QObject * m_timer; // just a QObject* so we're not tempted
                       // to call functions on it
    QMutext m_mutex; // protects 'm_timer'
public:
    explicit UpdateThread( QObject * parent=0 )
        : QThread( parent ), m_timer( 0 ) {}
    // ...
private:
    /* reimpl */ void run() {
        QTimer timer;
        // ...'timer' setup code goes here...
        {
            const QMutexLocker locker( &m_mutex );
            m_timer = &timer; // publish 'timer' through 'm_timer'
        }
        // main code of run()
        exec(); // start event loop so we get timer's timeout()s
                // and we can receive cross-thread method calls
        {
            const QMutexLocker locker( &m_mutex );
            m_timer = 0; // un-publish before we delete `timer`
        }
    }
public Q_SLOTS:
    void startTimer() {
        const QMutexLocker locker( &m_mutex );
        if ( !m_timer ) return;
        // perform cross-thread method call:
        QMetaObject::invokeMethod( m_timer, "start", Qt::QueuedConnection );
    }
    void stopTimer() {
        const QMutexLocker locker( &m_mutex );
        if ( !m_timer ) return;
        // perform cross-thread method call:
        QMetaObject::invokeMethod( m_timer, "stop", Qt::QueuedConnection );
    }
};

现在，这就是从 GUI 线程启动/停止计时器的方法。但您也询问了替代方案。

1. 将 tick() 代码移至 run() 中，每隔 t 调用 UpdateThread::start()毫秒。

   这是次优的，因为它会每隔 t 毫秒创建和销毁线程。线程创建仍然是一个昂贵的操作。另外，如果在您下次调用 start() 时 UpdateThread::run() 尚未完成，您将丢失计时器滴答声。

2. UpdateThread 如上所述。

   这还不错，但我想说，这不是惯用的多线程。如果计时器触发如此频繁，以至于仅会以某种方式减慢 GUI 线程的速度，那么这是一个很好的解决方案，尽管您也可能会以这种方式丢失计时器滴答声。

3. QThreadPool

   我最喜欢的。将执行 tick() 的代码移至 QRunnable::run() 的实现中，并在计时器触发时在线程池中对新的可运行对象进行排队。在这种情况下，计时器最自然地存在于 GUI 线程中，从而避免了如上所述的跨线程方法调用的需要。除非 GUI 线程本身超载，否则您不会错过任何计时器滴答声。您还可以免费缩放系统中的核心数量（如果您不希望这样做，请不要使用 QThreadPool::globalInstance() ，而是创建您自己的实例并调用 setMaxThreadCount(1)).