基本介绍

postEvent方法所属类为QCoreApplication,完整声明如下:

[static] void QCoreApplication::postEvent(QObject *receiver, QEvent *event, int priority = Qt::NormalEventPriority)

该方法的作用是将要发送的事件推送到对应线程的事件队列中,用于后续的事件循环(关于事件循环相关内容,请到本专栏中对应文章中去看)。

理解

该如何理解这个方法呢?我个人的理解是首先认识到这一个异步非阻塞的调用,说它异步是因为调用这个函数后,要发送的事件并没有立即推送给接收对象(receiver)进行处理,而是将其推送到事件队列,这个事件队列来自谁呢?事件队列是基于线程的,一个线程只有一个事件队列虽然可以启动多个事件循环,但是一个线程下的所有事件循环共享同一个事件调度器,一个事件调度器仅有一个事件队列。说他非阻塞是说将事件加入到事件队列后,立即返回,并不会造成调用者阻塞。一般用于跨线程之间的事件推送,比如线程A的对象a要发送一个事件到线程B的对象b,要使用该方法完成这个功能。

源码分析

post源码核心功能代码如下:

void QCoreApplication::postEvent(QObject *receiver, QEvent *event, int priority)
{
    ……
    QThreadData * volatile * pdata = &receiver->d_func()->threadData;
    QThreadData *data = *pdata;
    ……
    data->postEventList.addEvent(QPostEvent(receiver, event, priority));
    ……
    QAbstractEventDispatcher* dispatcher = data->eventDispatcher.loadAcquire();
    if (dispatcher)
        dispatcher->wakeUp();
}

通过上面的代码可以看到,data表示的一个对象的threadData(线程数据),其成员postEventList表示的是事件队列,AddEvent通过字面意思就能理解,即将事件加入到事件队列中。然后调用事件调度器的wakeup方法唤醒对应线程,通知器事件队列有了新数据,可以进行事件循环了,从这个角度理解,该操作可以防止程序死循环,满负荷运转。wakeup的方法如下:

void QEventDispatcherUNIX::wakeUp()
{
    Q_D(QEventDispatcherUNIX);
    d->threadPipe.wakeUp();
}

void QThreadPipe::wakeUp()
{
    if (wakeUps.testAndSetAcquire(0, 1)) {
#ifndef QT_NO_EVENTFD
        if (fds[1] == -1) {
            // eventfd
            eventfd_t value = 1;
            int ret;
            EINTR_LOOP(ret, eventfd_write(fds[0], value));
            return;
        }
#endif
        char c = 0;
        qt_safe_write(fds[1], &c, 1);
    }
}

有兴趣的朋友可以研究一下上面这部分代码,这里设计了QThreadPipe,这个类的作用我没有看明白,后续有时间研究一下,而且涉及了到了eventfd系统调用,该调用后续我再研究一下。

使用注意事项

  • 本方法属于异步调用,将要发布的事件添加到线程中事件调度器的事件队列中,调用后立即返回。
  • 调用本方法中的event参数为一个指针,该指针必须通过new申请,并且该对象的释放由该方法内部完成,用户无需单独释放该内存。
  • 该方式是一个静态方法,使用方法如下
QCoreApplication::postEvent(receive,event)
09-13 14:35