Qt线程(1) moveToThread

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

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

1. 创建一个用于计算的对象，该对象的运算相关函数防止在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");//!!按照需求添加
   }

2. 创建一个测试对象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;
   }

3. 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();
   }

4. 执行结果
   

　　

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