Qt线程(1) moveToThread

若在Qt准备使用线程类一般有两种方式(1) 采用WorkObject配合QThread进行使用 (2)继承QThread, 重载run()函数即可。
注:采用Qt::Concurrent之类的不在本文讨论范围内.

　　方式一、采用WorkObject配合QThread进行使用

创建一个用于计算的对象，该对象的运算相关函数防止在public slots 下：

 //..Object.h
 class CObject : public QObject
 {
     Q_OBJECT
 public:
     explicit CObject(QObject *parent = 0);
     ~CObject();

 signals:
     void sigFinish(const QString &s); //跨线程请注意使用const

 public slots:
     void Run();
     void Stop();

 private:
     bool m_bStop;
 };

 //..Object.cpp
 CObject::CObject(QObject *parent)
     : QObject(parent),m_bStop(false)
 {

 }

 void CObject::Run()
 {
     int i = 0;
     while(1)
     {
         if(m_bStop)
         {
             return;
         }
         qDebug()<<"Object TheradID = "<<QThread::currentThreadId();
         qDebug()<<"Run i = "<<i;
         sleep(1);
         if(++i == 10)
         {
             emit sigFinish("Finish");//信号是线程安全的,当然这得扯到后面的连接方式
         }
     }
 }

 void CObject::Stop()
 {
     m_bStop = true;
     emit sigFinish("Stop");//!!按照需求添加
 }

创建一个测试对象CTest

 //..test.h
 class CTest : public QObject
 {
     Q_OBJECT
 public:
     explicit CTest(QObject *parent = 0);
     void Run();
     void Stop();

 signals:

 private slots:
     void slotFinish(const QString &);

 private:
     QList<CObject *> m_ListObj;
 };

 //..test.cpp
 CTest::CTest(QObject *parent) : QObject(parent)
 {

 }

 void CTest::Run()
 {
     QThread *pThread = new QThread(this); // 只充当一个作为另个线程的入口
     CObject *pObj = new CObject; //注意:moveToThread不能使用在双亲对象上
     m_ListObj.append(pObj);

     qDebug()<<"Current Main Run Thread = "<<QThread::currentThreadId();

     connect(pObj,SIGNAL(sigFinish(QString)),pObj,SLOT(deleteLater()));
     connect(pObj,SIGNAL(sigFinish(QString)),pThread,SLOT(quit()));
     connect(pObj,SIGNAL(sigFinish(QString)),this,SLOT(slotFinish(QString)));

     connect(pThread,SIGNAL(started()),pObj,SLOT(Run()));
     connect(pThread,SIGNAL(finished()),pObj,SLOT(deleteLater()));

      pObj->moveToThread(pThread);

     pThread->start();
 }
 void CTest::Stop()
 {
     foreach (CObject *pObj, m_ListObj)
     {
         if(!QMetaObject::invokeMethod(pObj,"Stop",Qt::DirectConnection))//!!留个坑,为什么autoConnection会没反应
         {
             qDebug()<<"error";
         }
     }
     m_ListObj.clear();
 }

 void CTest::slotFinish(const QString &s)
 {
     qDebug()<<"Main Thread Receive:"<<s;
 }

main.cpp

 //..main.cpp
 int main(int argc, char *argv[])
 {
     QCoreApplication a(argc, argv);
     CTest test;
     test.Run();
     sleep(5);
     test.Stop();
     return a.exec();
 }

执行结果

　　Well Done,方式2见Qt线程(2) QThread中使用WorkObject?

秒客网

Qt线程(1) moveToThread

相关文章