如何监视Qt信号事件队列深度

Question

我的程序中有两个对象。一个物体正在发射信号。另一个在插槽中接收信号，并一个接一个地处理输入信号。两个对象都在不同的线程中运行。现在，我需要测量和监视接收对象的工作量。

问题是我不知道Qt信号队列中有多少信号正在等待第二个对象处理。有没有办法获取此队列的大小？还是有解决办法来知道仍然需要处理多少个信号？

Answer 1

该qGlobalPostedEventsCount（）是一个起点，但它仅适用于当前线程。

要轮询任意线程，我们可以使用 Qt 的内部结构。那么实现就非常简单了。即使线程被阻塞并且不处理事件，它也能工作。

// https://github.com/KubaO/stackoverflown/tree/master/questions/queue-poll-44440584
#include <QtCore>
#include <private/qthread_p.h>
#include <climits>

uint postedEventsCountForThread(QThread * thread) {
   if (!thread)
      return -1;
   auto threadData = QThreadData::get2(thread);
   QMutexLocker lock(&threadData->postEventList.mutex);
   return threadData->postEventList.size() - threadData->postEventList.startOffset;
}

uint postedEventsCountFor(QObject * target) {
   return postedEventsCountForThread(target->thread());
}

如果真的不希望使用私有 API，我们可以有一个不那么直接的解决方案，但需要更多的开销。首先，让我们回想一下，“在某个对象的线程中做事”的最低开销方式是在事件的析构函数中做所说的“事”——有关更多详细信息，请参阅此答案。我们可以将最高优先级的事件发布到目标对象的事件队列。该事件包装了一个任务，该任务调用qGlobalPostedEventsCount、更新计数变量并释放我们随后获取的互斥锁。在获取互斥锁时，计数具有返回的有效值。如果目标线程无响应且请求超时，-1则返回。

uint qGlobalPostedEventsCount(); // exported in Qt but not declared
uint postedEventsCountForPublic(QObject * target, int timeout = 1000) {
   uint count = -1;
   QMutex mutex;
   struct Event : QEvent {
      QMutex & mutex;
      QMutexLocker lock;
      uint & count;
      Event(QMutex & mutex, uint & count) :
         QEvent(QEvent::None), mutex(mutex), lock(&mutex), count(count) {}
      ~Event() {
         count = qGlobalPostedEventsCount();
      }
   };
   QCoreApplication::postEvent(target, new Event(mutex, count), INT_MAX);
   if (mutex.tryLock(timeout)) {
      mutex.unlock();
      return count;
   }
   return -1;
}

和一个测试工具：

int main(int argc, char ** argv) {
   QCoreApplication app(argc, argv);
   struct Receiver : QObject {
      bool event(QEvent *event) override {
         if (event->type() == QEvent::User)
            QThread::currentThread()->quit();
         return QObject::event(event);
      }
   } obj;
   struct Thread : QThread {
      QMutex mutex;
      Thread() { mutex.lock(); }
      void run() override {
         QMutexLocker lock(&mutex);
         QThread::run();
      }
   } thread;
   thread.start();
   obj.moveToThread(&thread);
   QCoreApplication::postEvent(&obj, new QEvent(QEvent::None));
   QCoreApplication::postEvent(&obj, new QEvent(QEvent::None));
   QCoreApplication::postEvent(&obj, new QEvent(QEvent::None));
   QCoreApplication::postEvent(&obj, new QEvent(QEvent::User));
   auto count1 = postedEventsCountFor(&obj);
   thread.mutex.unlock();
   auto count2 = postedEventsCountForPublic(&obj);
   thread.wait();
   auto count3 = postedEventsCountFor(&obj);
   Q_ASSERT(count1 == 4);
   Q_ASSERT(count2 == 4);
   Q_ASSERT(count3 == 0);
}

QT = core-private
CONFIG += console c++11
CONFIG -= app_bundle
TARGET = queue-poll-44440584
TEMPLATE = app
SOURCES += main.cpp