50 lines
1012 B
C++
50 lines
1012 B
C++
#ifndef PARALLELDIRSCANNER_H
|
|
#define PARALLELDIRSCANNER_H
|
|
|
|
#include <QObject>
|
|
#include <QMutex>
|
|
#include <atomic>
|
|
#include <QThreadPool>
|
|
#include "concurrentqueue.h"
|
|
class ParallelDirScanner : public QObject
|
|
{
|
|
Q_OBJECT
|
|
protected:
|
|
QStringList ignorePatterns;
|
|
QThreadPool threadpool;
|
|
|
|
unsigned int finishedWorkers = 0;
|
|
unsigned int processedPaths = 0;
|
|
|
|
std::atomic<bool> stopToken;
|
|
|
|
bool running = false;
|
|
|
|
QVector<QString> paths;
|
|
ConcurrentQueue<QString> targetPathsQueue;
|
|
ConcurrentQueue<QString> resultPathsQueue;
|
|
unsigned int getThreadsNum() const;
|
|
|
|
public:
|
|
ParallelDirScanner();
|
|
|
|
ConcurrentQueue<QString> &getResults();
|
|
void setIgnorePatterns(QStringList patterns);
|
|
void setPaths(QVector<QString> paths);
|
|
void scan();
|
|
bool isRunning();
|
|
|
|
unsigned int pathCount();
|
|
|
|
signals:
|
|
void scanComplete();
|
|
void progress(int, int);
|
|
public slots:
|
|
void cancel();
|
|
private slots:
|
|
void handleWorkersProgress(unsigned int progress);
|
|
void handleWorkersFinish();
|
|
};
|
|
|
|
#endif // PARALLELDIRSCANNER_H
|