我读到我应该使用 worker 对象并通过 moveToThread 将其移动到线程,而不是直接从 QThread 继承。但是我找不到如何在我的对象 worker 中停止循环的解决方案。例如我有测试循环:
void CollectionWorker::doWork()
{
for (int i = 0; i < 10; ++i) {
sleep(1);
emit ping(i);
}
}
现在我将这个对象移动到线程:
worker->moveToThread(mTh);
这工作正常。但是当我调用 mTh.quit() 时,线程正在等待,直到 doWork 中的循环结束。当我直接从 QThread 继承时,然后在每个循环上我可以检查线程状态并在 thred 完成时中断循环,但不知道如何在 worker 对象中执行此操作。我可以只在工作对象中创建一些标志并将其从主线程切换吗?或者我可以找到线程所有者并检查它的状态吗?或者在启动线程之前更好,在工作对象中设置线程指针然后检查状态?最好的线程安全解决方案是什么?
问候
最佳答案
在线程对象上调用 quit() 或 exit() 将简单地结束线程的事件循环(如果有线程正在运行)。但是正如您正确指出的那样,最初的问题仍然存在。如果 worker 函数已经被事件循环执行过并且是一个具有 forever 构造的长时间运行的函数怎么办。对 quit() 或 exit() 的调用只会等待辅助函数返回。
除了使调用者可以使用公共(public)函数(这将更改内部标志)之外,还可以建议几种方法。
- 在您的工作类中提供终止信号和插槽。内容如下。
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();
使用信号和槽而不是普通成员函数的原因之一是,如果您的辅助函数在同步代码块内执行一些长时间运行的任务,则公共(public)函数将保持阻塞状态,直到它获得对同步对象的访问权限。如果您的公共(public)终止方法的调用线程是 UI 线程,这可能会产生不利影响。
- 如果您使用的是 Qt 5.2 或更高版本,这是另一种更简洁的方法
使用 QThread 的 requestInterruption() 方法。此方法在线程对象中设置一个咨询标志,您可以通过 doWork() 函数中的 isInterruptionRequested() 函数调用来检查该标志。请参阅 QThread::isInterruptionRequested 中给出的以下代码片段文档。
void long_task() {
forever {
if ( QThread::currentThread()->isInterruptionRequested() ) {
return;
}
}
}
也可以在这里直接调用quit()结束线程的事件循环。
关于c++ - QThread - 如何停止 worker ?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15269051/