🐛fix task not started asynchronously

🏷️update version string

CMakeLists.txt

@@ -6,7 +6,7 @@ set(BINARY_NAME minetcore)
 set(CMAKE_CXX_STANDARD 17)
 
 project(${PROJECT_NAME}
-    VERSION 1.0.1
+    VERSION 1.0.2
     DESCRIPTION "A mini HTTP server library with C++"
     LANGUAGES CXX)
 

src/common/Base.cpp

@@ -2,6 +2,6 @@
 
 MINET_BEGIN
 
-const char* Version = "0.1.0";
+const char* Version = "1.0.2";
 
 MINET_END

src/threading/Task.h

@@ -47,6 +47,7 @@ class Task final : public std::enable_shared_from_this<Task>
 private:
     std::packaged_task<void()> _task;
     std::future<void> _future;
+    std::thread _thread;
 };
 
 /**
@@ -79,6 +80,7 @@ template <typename TResult> class ValueTask final : public std::enable_shared_fr
 private:
     std::packaged_task<TResult()> _task;
     std::future<TResult> _future;
+    std::thread _thread;
 };
 
 /*
@@ -116,8 +118,12 @@ inline Ref<Task> Task::Completed()
 
 inline Ref<Task> Task::StartAsync()
 {
+    if (_future.valid())
+    {
+        throw std::runtime_error("Task already started");
+    }
     _future = _task.get_future();
-    _task();
+    _thread = std::thread(std::move(_task));
     return shared_from_this();
 }
 
@@ -127,6 +133,7 @@ inline void Task::Await()
     {
         throw std::runtime_error("Task not started");
     }
+    _thread.join();
     _future.get();
 }
 
@@ -175,8 +182,12 @@ template <typename TResult> Ref<ValueTask<TResult>> ValueTask<TResult>::Complete
 
 template <typename TResult> Ref<ValueTask<TResult>> ValueTask<TResult>::StartAsync()
 {
+    if (_future.valid())
+    {
+        throw std::runtime_error("Task already started");
+    }
     _future = _task.get_future();
-    _task();
+    _thread = std::thread(std::move(_task));
     return this->shared_from_this();
 }
 
@@ -186,6 +197,7 @@ template <typename TResult> TResult ValueTask<TResult>::Await()
     {
         throw std::runtime_error("Task not started");
     }
+    _thread.join();
     return _future.get();
 }