带有movetothread的qt线程

unf*_*ous 16 c++ qt multithreading

我正在尝试使用线程创建一个程序:主循环开始.当测试返回true时,我创建一个对象,我希望该对象在另一个线程中工作,然后返回并开始测试.

QCoreApplication a(argc, argv);
while(true){
    Cmd cmd;
    cmd =db->select(cmd);
    if(cmd.isNull()){ 
        sleep(2);  
        continue ;
    }
    QThread *thread = new QThread( );
    process *class= new process ();
    class->moveToThread(thread);
    thread->start();

    qDebug() << " msg"; // this doesn't run until  class finish it's work 
}
return a.exec();
Run Code Online (Sandbox Code Playgroud)

问题是,当我启动新线程时,主线程停止并等待新线程的完成.

sme*_*lin 58

规范的Qt方式如下所示:

 QThread* thread = new QThread( );
 Task* task = new Task();

 // move the task object to the thread BEFORE connecting any signal/slots
 task->moveToThread(thread);

 connect(thread, SIGNAL(started()), task, SLOT(doWork()));
 connect(task, SIGNAL(workFinished()), thread, SLOT(quit()));

 // automatically delete thread and task object when work is done:
 connect(task, SIGNAL(workFinished()), task, SLOT(deleteLater()));
 connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));

 thread->start();
Run Code Online (Sandbox Code Playgroud)

如果你不熟悉信号/槽,Task类看起来像这样:

class Task : public QObject
{
Q_OBJECT
public:
    Task();
    ~Task();
public slots:
    // doWork must emit workFinished when it is done.
    void doWork();
signals:
    void workFinished();
};
Run Code Online (Sandbox Code Playgroud)

  • smerlin:感谢一个非常好的答案. (2认同)