我想在Qt中发出一个信号,该信号来自我使用QtConcurrent :: run调用的函数。
是否可能?看起来我的槽从未被调用。所有的信号、槽和函数都属于同一个类对象。我尝试在主线程和从线程中进行连接。我不在意信号和槽是否在同一个线程中,我只是想让它发生。
谢谢
是否可能?看起来我的槽从未被调用。所有的信号、槽和函数都属于同一个类对象。我尝试在主线程和从线程中进行连接。我不在意信号和槽是否在同一个线程中,我只是想让它发生。
谢谢
// https://github.com/KubaO/stackoverflown/tree/master/questions/concurrent-emit-qt4-7114421
#include <QtCore>
class Helper : public QObject {
Q_OBJECT
public:
int n = 0;
Q_SLOT void increment() {
Q_ASSERT(QThread::currentThread() == qApp->thread());
n++;
}
};
int main(int argc, char **argv)
{
QCoreApplication app(argc, argv);
Helper helper;
Q_ASSERT(helper.n == 0);
QtConcurrent::run([&]{
Q_ASSERT(QThread::currentThread() != qApp->thread());
QObject src;
QObject::connect(&src, SIGNAL(destroyed(QObject*)), &helper, SLOT(increment()));
QObject::connect(&src, SIGNAL(destroyed(QObject*)), &app, SLOT(quit()));
});
app.exec();
Q_ASSERT(helper.n == 1);
}
#include "main.moc"
#include <QtConcurrent>
int main(int argc, char **argv)
{
QCoreApplication app(argc, argv);
int n = 0;
Q_ASSERT(n == 0);
QtConcurrent::run([&]{
Q_ASSERT(QThread::currentThread() != qApp->thread());
QObject src;
QObject::connect(&src, &QObject::destroyed, &app, [&]{
Q_ASSERT(QThread::currentThread() == qApp->thread());
n ++;
qApp->quit();
});
});
app.exec();
Q_ASSERT(n == 1);
}
您可以使用Qt::QueuedConnection
来建立连接(将其传递给connect
调用,以建立连接),因为信号始终会从与接收对象线程不同的线程发出。
Qt::AutoConnection
也会执行相同的操作,并将信号添加到接收对象的线程事件队列中。
如果接收线程被阻塞,因此永远不会重新进入事件队列,则无法通过接收对象的插槽接收信号。
QThread::currentThread
)和目标线程(receiver->thread()
)之间进行的。发送对象的线程在该决定中没有任何作用。 - Kuba hasn't forgotten Monica是的,这是可能的。 只需要看一个小例子:
在这个例子中,我们想要实现多线程。longProcess函数进入线程池,在线程池中处理后,长时间处理函数的答案会回到主线程。
Test.h
Class Test: public QObject
{
Q_OBJECT
public:
explicit Test(QObject *parent = nullptr);
void resultAvailable();
static void doLongProcess(Test *test);
signals:
void finishedProcess(const QString &massage);
public slots:
void captureSignal(const QString &message);
};
Test.cpp
void Test::resultAvailable()
{
QtConcurrent::run(&ContactsModelManager::doLongProcess, this);
connect(this , &Test::finishedProcess,
this , &Test::captureSignal);
}
//attention!! doLongProcess is static fnuction
void Test::doLongProcess(Test *test)
{
//this process is very long
test->longProcess();
}
void Test::longProcess()
{
//do your process
//at the end emit your signal
emit finishedProcess("finished process in another thread");
}
void Test::captureSignal(const QString &message)
{
Qdebug() << "message is: " << message;
}