class CustomSysmodel : public QFileSystemModel { Q_OBJECT public: CustomSysmodel(QWidget *parent = Q_NULLPTR) : QFileSystemModel(parent), m_limit(100), m_timer(new QTimer(this)), m_threadPool(new QThreadPool(this)) { connect(m_timer, &QTimer::timeout, this, &CustomSysmodel::loadMoreFiles); m_timer->setInterval(2000); } public slots: void fetchFiles(const QString &path) { emit started(); FileSystemWorker* worker = new FileSystemWorker; connect(worker, &FileSystemWorker::fileFound, this, &CustomSysmodel::fileFound); connect(worker, &FileSystemWorker::finished, this, &CustomSysmodel::finished); worker->setPath(path); m_threadPool->start(worker); } private: int m_limit; QTimer *m_timer; QThreadPool *m_threadPool; }; class FileSystemWorker : public QObject, public QRunnable { Q_OBJECT public: FileSystemWorker(QObject *parent = nullptr) : QObject(parent) {} void setPath(const QString& path) { m_path = path; } void run() override { QFileInfoList files = QDir(m_path).entryInfoList(QDir::Files); foreach (const QFileInfo &fileInfo, files) { emit fileFound(fileInfo.absoluteFilePath()); } emit finished(); } signals: void started(); void finished(); void fileFound(const QString &filePath); private: QString m_path; }; 想要实现单独线程读取文件,再发送给主线程,目的是为了访问百万级文件时,可以实现其他线程在读取后续文件时,主线程流畅访问已近读取到的文件。 ,给出完整的修改方案
时间: 2024-02-21 21:57:29 浏览: 94
以下是修改方案:
1. 在 CustomSysmodel 类的构造函数中添加一个信号槽连接,将 worker 线程的 started() 信号与 CustomSysmodel 类的 started() 信号相连,当 worker 线程开始运行时,CustomSysmodel 类会发出 started() 信号,通知主线程开始处理。
2. 在 CustomSysmodel 类中添加一个新的私有槽函数 loadMoreFiles(),该函数会检查当前已经加载的文件数量,如果不足 m_limit,则会继续加载更多文件,直到达到 m_limit 或者已经加载完所有文件。
3. 在 CustomSysmodel 类的 fetchFiles() 函数中,创建一个 FileSystemWorker 对象,并将该对象与 CustomSysmodel 类的 fileFound() 和 finished() 信号相连。然后将该对象加入线程池中,并调用该对象的 setPath() 函数,设置需要读取的文件路径。
4. 在 FileSystemWorker 类中,重载 run() 函数,该函数会在 worker 线程中运行,使用 QDir 类读取指定目录下的所有文件,并将文件路径通过 fileFound() 信号发送给 CustomSysmodel 类的主线程。当所有文件都读取完毕后,会通过 finished() 信号通知主线程。
下面是完整的修改方案:
```
class CustomSysmodel : public QFileSystemModel {
Q_OBJECT
public:
CustomSysmodel(QWidget *parent = Q_NULLPTR) : QFileSystemModel(parent),
m_limit(100),
m_timer(new QTimer(this)),
m_threadPool(new QThreadPool(this))
{
connect(m_timer, &QTimer::timeout, this, &CustomSysmodel::loadMoreFiles);
m_timer->setInterval(2000);
}
public slots:
void fetchFiles(const QString &path)
{
emit started();
FileSystemWorker* worker = new FileSystemWorker;
connect(worker, &FileSystemWorker::fileFound, this, &CustomSysmodel::fileFound);
connect(worker, &FileSystemWorker::finished, this, &CustomSysmodel::finished);
worker->setPath(path);
m_threadPool->start(worker);
}
private slots:
void loadMoreFiles()
{
int rowCount = this->rowCount();
if (rowCount < m_limit) {
int toLoad = m_limit - rowCount;
this->fetchMore(QModelIndex());
QModelIndex index = this->index(rowCount);
for (int i = 0; i < toLoad; ++i) {
if (!index.isValid()) {
break;
}
QString filePath = this->filePath(index);
emit fileFound(filePath);
index = this->index(rowCount + i + 1);
}
}
}
signals:
void started();
void finished();
void fileFound(const QString &filePath);
private:
int m_limit;
QTimer *m_timer;
QThreadPool *m_threadPool;
};
class FileSystemWorker : public QObject, public QRunnable {
Q_OBJECT
public:
FileSystemWorker(QObject *parent = nullptr) : QObject(parent) {}
void setPath(const QString& path) { m_path = path; }
void run() override
{
QFileInfoList files = QDir(m_path).entryInfoList(QDir::Files);
foreach (const QFileInfo &fileInfo, files) {
emit fileFound(fileInfo.absoluteFilePath());
}
emit finished();
}
signals:
void started();
void finished();
void fileFound(const QString &filePath);
private:
QString m_path;
};
```
阅读全文