added better cleanup

Author: OjasTalgaonkar

source/include/threadPool.hh

@@ -5,11 +5,13 @@
 #include <condition_variable>
 #include <cstddef>
 #include <functional>
+#include <iostream>
 #include <mutex>
 #include <queue>
 #include <thread>
 #include <vector>
 
+
 class ThreadPool {
   public:
     ThreadPool(size_t threadCount);

source/src/efficientFinder.cc

@@ -35,6 +35,15 @@ int processFile(const fs::path &filePath, ThreadPool &pool) {
     return 0;
 }
 
+ThreadPool *globalPool = nullptr;
+
+// void cleanup() {
+//     if (globalPool) {
+//         globalPool->stopPool();
+//         std::cout << "thread cleared";
+//     }
+// }
+
 int main() {
     std::string root;
 
@@ -48,6 +57,8 @@ int main() {
 #endif
 
     ThreadPool pool(std::thread::hardware_concurrency());
+    globalPool = &pool;  // Store reference to pool
+    // std::atexit(cleanup);  // Register cleanup() function
 
     fs::recursive_directory_iterator it(root, fs::directory_options::skip_permission_denied), end;
     while (it != end) {

source/src/find.cc

@@ -82,7 +82,6 @@ bool checker(std::string inputfile) {
         std::cout << "LLLLLLLLOOOOOOOOWWWWWW  T A P E R  F A D E\n";
         wordMap["low"] = wordMap["taper"] = wordMap["fade"] = false;
         std::exit(0);
-
         return true;
     }
     return false;

source/src/finder.exe

@@ -1,6 +1,7 @@
 #include "../include/threadPool.hh"
 
 #include <cstddef>
+#include <cstdlib>
 #include <functional>
 #include <mutex>
 
@@ -10,7 +11,12 @@ ThreadPool::ThreadPool(size_t threadCount) {
     }
 }
 
-ThreadPool::~ThreadPool() { stopPool(); }
+ThreadPool::~ThreadPool() {
+    std::cout << "hello";
+    stopPool();
+}
+
+std::atexit(stopPool);
 
 void ThreadPool::stopPool() {
     stop = true;