void fetchFiles(const QString &path) { emit started(); QThread *thread = new QThread; FileSystemWorker *worker = new FileSystemWorker; worker->moveToThread(thread); connect(thread, &QThread::started, worker, [this, worker, path]() { worker->fetchFiles(path); }); connect(worker, &FileSystemWorker::fileFound, this, &CustomSysmodel::fileFound); connect(worker, &FileSystemWorker::finished, thread, &QThread::quit); connect(worker, &FileSystemWorker::finished, worker, &FileSystemWorker::deleteLater); connect(thread, &QThread::finished, thread, &QThread::deleteLater); connect(worker, &FileSystemWorker::finished, this, &CustomSysmodel::finished); thread->start(); thread->wait(); delete thread; delete worker;} wait()函数阻塞主线程, 改写为用Qt::QueuedConnection实现功能
时间: 2024-01-12 13:02:18 浏览: 28
改写后的代码如下:
```
void fetchFiles(const QString &path) {
emit started();
QThread *thread = new QThread;
FileSystemWorker *worker = new FileSystemWorker;
worker->moveToThread(thread);
connect(thread, &QThread::started, worker, [this, worker, path]() {
worker->fetchFiles(path);
});
connect(worker, &FileSystemWorker::fileFound, this, &CustomSysmodel::fileFound);
connect(worker, &FileSystemWorker::finished, thread, &QThread::quit);
connect(worker, &FileSystemWorker::finished, worker, &FileSystemWorker::deleteLater);
connect(thread, &QThread::finished, thread, &QThread::deleteLater);
connect(worker, &FileSystemWorker::finished, this, &CustomSysmodel::finished);
thread->start();
// 使用 Qt::QueuedConnection 将 wait() 改为槽函数
QMetaObject::invokeMethod(thread, &QThread::wait, Qt::QueuedConnection);
}
```
使用 Qt::QueuedConnection 将 wait() 函数改为槽函数,以避免阻塞主线程。当线程执行完成时,wait() 函数会被调用,等待线程结束。