Thread pool optimizer

mhtvsSFrpHdE · Aug 8, 2022 · 7b73735 · 7b73735
1 parent 6d6db46
commit 7b73735
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 0 deletions.
diff --git a/qpp/prefetch/Source/Core/Thread/read_thread.cpp b/qpp/prefetch/Source/Core/Thread/read_thread.cpp
@@ -9,6 +9,7 @@ QMutex ReadThread::printLock(QMutex::NonRecursive);
 QStringList ReadThread::excludeFolders = QStringList();
 QStringList ReadThread::priorityIncludePatterns = QStringList();
 bool ReadThread::pause = false;
+QList<QRunnable *> ReadThread::pendingDeleteThread = QList<QRunnable *>();
 
 ReadThread::ReadThread(QString filePath)
 {
@@ -65,6 +66,12 @@ bool ReadThread::run_SearchInclude()
     return false;
 }
 
+void ReadThread::run_RequestDelete()
+{
+    QRunnable *currentThreadPointer = this;
+    pendingDeleteThread.append(currentThreadPointer);
+}
+
 void ReadThread::run_read()
 {
     // Read file
@@ -97,6 +104,7 @@ void ReadThread::run()
     {
         if (run_SearchExclude())
         {
+            run_RequestDelete();
             return;
         }
     }

diff --git a/qpp/prefetch/Source/Core/Thread/read_thread.h b/qpp/prefetch/Source/Core/Thread/read_thread.h
@@ -23,6 +23,9 @@ class ReadThread : public QRunnable
     //     each read will not happen but return immediately
     static bool pause;
 
+    // A thread that report it can be delete goes here
+    static QList<QRunnable *> pendingDeleteThread;
+
     void run() override;
 
 private:
@@ -48,6 +51,9 @@ class ReadThread : public QRunnable
     //     true: File is excluded
     bool run_SearchExclude();
 
+    // This file is excluded, delete read thread after first run
+    void run_RequestDelete();
+
     // Prefetch file
     void run_read();
 };
diff --git a/qpp/prefetch/Source/Core/read_file.cpp b/qpp/prefetch/Source/Core/read_file.cpp
@@ -213,8 +213,18 @@ bool ReadFile::start_runThreadPool(int rescanInterval)
         readThreadPool->start(readThreadQueue[i]);
     }
 
+    // Delete excluded file thread
     readThreadPool->waitForDone();
 
+    auto dbg_PendingDeleteThread = &ReadThread::pendingDeleteThread;
+    for (int i = 0; i < ReadThread::pendingDeleteThread.size(); ++i)
+    {
+        auto threadPointer = ReadThread::pendingDeleteThread[i];
+        readThreadQueue.removeOne(threadPointer);
+        delete threadPointer;
+    }
+    ReadThread::pendingDeleteThread.clear();
+
     // Get code execute time
     auto threadPoolTimeConsumedMiliseconds = threadPoolTimer.elapsed();
     auto threadPoolTimeConsumedFormatedString = QTime()