QThread - 如何阻止工人？

Question

我在读我应该使用worker对象，并通过moveToThread将其移动到线程，而不是直接从QThread继承。但我无法找到解决方案如何停止我的对象工人循环。例如，我有测试回路：

void CollectionWorker::doWork() 
{ 
    for (int i = 0; i < 10; ++i) { 
     sleep(1); 
     emit ping(i); 
    } 
} 

现在我提出这个对象的线程：

worker->moveToThread(mTh); 

这是工作的罚款。但是当我调用mTh.quit（）时，线程正在等待，直到doWork中的循环结束。当我直接从QThread继承，然后在每个循环中，我可以检查线程状态并在完成完成时断开循环，但不知道如何在工作对象中执行此操作。我可以在工作对象中创建一些标志并将其从主线程中切换出来吗？或者，也许我可以找到线程所有者并检查它的状态？或者，也许在开始线程之前更好，在工作对象中设置线程指针，然后检查状态？什么是最好的线程安全解决方案？

Regards

Answer 1

编辑：对不起，我误解了你的问题。

有几种选择。您可以创建一些标志，并在处理循环的每次迭代之前检查标志是否已设置。或者，如果您在列表/队列中处理数据，您可能会发信号通知进程终止一个特殊的数据结束元素。

Answer 2

Qt中的惯用的方式来破坏辅助线程使用信号/槽接口：

为了这个工作CollectionWorker必须从一个QObject类继承和声明Q_OBJECT宏。

Answer 3

如果有任何运行，调用线程对象的quit（）或exit（）将简单地结束线程的事件循环。但正如您正确指出的那样，原始问题仍然是一样的。如果工作者函数已经被事件循环执行并且是具有永久构造的长时间运行的函数呢？对quit（）或exit（）的调用只需等待worker函数返回即可。

除了向调用者提供公共函数外，还可以建议两种方法，这些方法会改变内部标志。

• 给你的工人阶级一个终止信号和插槽。如下所示。

    signals: 
     void signalTermination(); 
    public slots: 
     void setTerminationFlag(); 
    private: 
     QMutex mutex; 
     bool terminationRequested; 

你的插槽看起来像什么。

void setTerminationFlag() 
{ 
    QMutexLocker locker(&mutex); 
    terminationRequested = true; 
} 

然后，您可以在永久循环的每次迭代中检查doWork函数中的变量。

mutex.lock(); 
if(terminationRequested) 
{ 
    //break from loop and effectively doWork function 
} 
mutex.unlock(); 

对使用​​，而不是普通的成员函数的信号和槽的原因是，如果你的工人函数是做同步的代码块中需要长时间运行的任务，公共职能将保持封锁，直到它得到的访问同步对象。如果公共终止方法的调用线程是UI线程，这可能会产生不利影响。

• 另一个干净和简单的方法，如果你使用的是Qt 5.2起

使用requestInterruption（）的QThread的方法。此方法在线程对象中设置咨询标志，您可以在doWork（）函数中通过isInterruptionRequested（）函数调用来检查该标志。请参阅QThread::isInterruptionRequested文档中给出的以下代码片段。

void long_task() { 
    forever { 
     if (QThread::currentThread()->isInterruptionRequested()) { 
      return; 
     } 
    } 
} 

您也可以直接调用quit（）来结束线程的事件循环。

Answer 4

我有和Dibo一样的问题。我在我的doWork()函数中运行了一个很长的计算循环，并且需要能够从我的主线程中停止它。

查迪克罗伯特的答案没有为我做的伎俩。第一个建议的表现与他为成员函数描述的一样。也就是说，虽然我们正在使用信号和插槽，但是从主线程中发出的信号调用setTerminationFlag插槽，并正确连接到它，只有在循环结束后才会执行。但是，也许我在执行方面做了错误。如果它确实应该工作，请让我知道，因为它似乎是交易断路器。

他的第二种替代方法是使用QThread::currentThread()->isInterruptionRequested()来告诉线程停止，如果不是因为你不能重置这个标志，而你打算重新使用线程和worker来执行一些类似的处理密集循环如果不一样的话。当然，你可以通过停止和启动线程来完成它，但是我不确定它是否不会有像清空执行队列那样的不利影响。这个问题实际上帐为bug report和蒂亚戈Macieira（Qt的主要开发者）提到那里，如果我可以引述他：

的requestInterruption功能的目的是完成线程。

这使得requestInterruption不适合作业，因为它仅在线程开始和结束时重置。

一个解决方案，我发现，这似乎不是所有的清洁对我来说，是包括QCoreApplication在工人阶级和时间打电话QCoreApplicaton::processEvents()时间，来处理Chadick Robbert的第一个建议那些排队的信号或更新工作者对线程之间共享标志变量的类感知。

因为你的循环中调用QCoreApplicaton::processEvents()可以减缓它极大地我做的是一样的东西：

for(unsigned long int i=0; i<800000000 && !*stop; i++){ 
    f += (double)i * .001; // dummy calculation 
    if(i%10000000 == 0) // Call it only from time to time 
     QCoreApplication::processEvents(); // update *stop according to main Thread 
} 

正如你所看到的，用此溶液循环只会在“千万”整数倍打破这可能不适合某些使用情况。

如果有人知道这个杀手解决方案，我很乐意听到。