Implement task submission and add basic test

Author: darcyg32

.vscode/settings.json

@@ -0,0 +1,5 @@
+{
+  "files.associations": {
+    "mutex": "cpp"
+  }
+}

main.exe

@@ -1,9 +1,25 @@
 #include "scheduler.hpp"
 #include <iostream>
+#include <chrono>
+#include <thread>
 
 int main() {
 
-    std::cout << "Hello, world!\n";
+    // Create a scheduler with 4 worker threads
+    Scheduler scheduler(4);
 
+    // Submit some tasks
+    for (int i = 0; i < 10; ++i) {
+        scheduler.submit([i]() {
+            std::cout << "Task " << i << " executed by thread\n";
+            // Simulate some work
+            std::this_thread::sleep_for(std::chrono::milliseconds(100));
+        });
+    }
+
+    // Give tasks time to execute
+    std::this_thread::sleep_for(std::chrono::seconds(2));
+
+    std::cout << "Main thread finished\n";
     return 0;
 }

src/main.cpp

@@ -29,13 +29,3 @@ Scheduler::Scheduler(size_t num_threads) : shutdown_(false) {
         });
     }
 }
-
-template<typename F>
-void Scheduler::submit(F&& task) {
-    {
-        std::lock_guard<std::mutex> lock(queue_mutex_);
-        task_queue_.emplace(std::forward<F>(task));
-    }
-    // Notify one waiting worker thread that a task is available
-    condition_.notify_one();
-}

src/scheduler.cpp

@@ -31,7 +31,14 @@ class Scheduler {
 
         // Submit a task to be executed by a worker thread
         template<typename F>
-        void submit(F&& task);
+        void submit(F&& task) {
+            {
+                std::lock_guard<std::mutex> lock(queue_mutex_);
+                task_queue_.emplace(std::forward<F>(task));
+            }
+            // Notify one waiting worker thread that a task is available
+            condition_.notify_one();
+        }
 };
 
 #endif