问题:
在 Qt 中,您希望在任何具有事件循环的线程中执行 lambda 或仿函数,类似于Objective-C 中的 GCD 调度队列。
解决方案:
解决方案的核心是传递一个事件,将函子包装到驻留在所需线程中的消费者对象。此操作称为 元调用发布,可以通过多种方式实现。
Qt 5.10 及以上 TL;DR:
您可以调用 QObject 或 QThread 上的方法直接:
// Invoke on the main thread QMetaObject::invokeMethod(qApp, []{ ... }); // Invoke on an object's thread QMetaObject::invokeMethod(obj, []{ ... }); // Invoke on a particular thread QMetaObject::invokeMethod( QAbstractEventDispatcher::instance(thread), []{ ... });
TL;函子的DR:
提供了几个模板函数来将函子包装在适当的事件对象中,使元调用发布变得方便。
// Post to the main thread sync void execInMainThread_sync(std::function<void(void)> func) { if(qApp->thread() == QThread::currentThread()) func(); else { ((App*) qApp)->invokeGenericExec(func, Qt::BlockingQueuedConnection); } } // Post to the main thread async void execInMainThread_async(std::function<void(void)> func) { ((App*) qApp)->invokeGenericExec(func, Qt::QueuedConnection); }
TL;DR方法/槽:
对于方法或槽,定义一个宏来处理元调用发布。
#define POST_METHOD(obj, method) \ QObject src; \ QObject::connect(&src, &QObject::destroyed, obj, method, \ Qt::QueuedConnection);
通用代码:
提供的代码包括常见的辅助函数和宏,它们抽象了元调用发布实现以在不同的环境中使用
示例:
void test1() { QThread t; QObject o; o.moveToThread(&t); // Execute in given object's thread postToObject([&]{ o.setObjectName("hello"); }, &o); // or postToObject(std::bind(&QObject::setObjectName, &o, "hello"), &o); // Execute in given thread postToThread([]{ qDebug() << "hello from worker thread"; }); // Execute in the main thread postToThread([]{ qDebug() << "hello from main thread"; }); }
附加说明:
如果您的目标线程没有事件循环例如工作线程,您可能需要一种机制来启动线程内的事件循环。例如,如果使用单次计时器进行元调用发布,则可以使用 QThread::exec() 启动事件循环。
以上是如何在特定的 Qt 线程中执行 Functor 或 Lambda,类似于 GCD?的详细内容。更多信息请关注PHP中文网其他相关文章!