diff --git a/Server/src/server.cpp b/Server/src/server.cpp index 8111694..a9cd093 100644 --- a/Server/src/server.cpp +++ b/Server/src/server.cpp @@ -59,10 +59,12 @@ int main() { spdlog::info("Waiting for connection..."); sock.accept(clientSock, clientAddr); - // threadPool.enqueueJob(_TCPClient, std::move(clientSock), clientAddr); + threadPool.enqueueJob(_TCPClient, std::move(clientSock), clientAddr); Chattr::Thread thread_(_TCPClient, std::move(clientSock), clientAddr); thread_.detach(); + + Sleep(10000000); } } diff --git a/include/Utils/Thread.hpp b/include/Utils/Thread.hpp index b6e3442..8035585 100644 --- a/include/Utils/Thread.hpp +++ b/include/Utils/Thread.hpp @@ -16,14 +16,14 @@ class Thread { public: #ifdef _WIN32 static unsigned __stdcall thread_func(LPVOID param) { - auto task = static_cast*>(param); + auto task = static_cast*>(param); (*task)(); delete task; return 0; } #elif __linux__ static void* thread_func(void *param) { - auto task = static_cast*>(param); + auto task = static_cast*>(param); (*task)(); delete task; return 0; @@ -42,27 +42,27 @@ public: auto boundFunc = [this, __f = std::move(__f), ... __args = std::move(__args)]() mutable { returnValuePtr = new std::invoke_result_t<_Callable, _Args...>(__f(std::move(__args)...)); }; - std::function funcPtr = std::move(boundFunc); + std::packaged_task* funcPtr = new std::packaged_task(std::move(boundFunc)); #ifdef _WIN32 - handle_ = (HANDLE)_beginthreadex(nullptr, 0, thread_func, new std::function(std::move(funcPtr)), 0, nullptr); + handle_ = (HANDLE)_beginthreadex(nullptr, 0, thread_func, funcPtr, 0, nullptr); #elif __linux__ pthread_create(&handle_, NULL, thread_func, funcPtr); #endif } - /*template + template requires (!std::is_same_v, Thread>) && std::is_void_v> Thread(_Callable&& __f, _Args&&... __args) { auto boundFunc = [this, __f = std::move(__f), ... __args = std::move(__args)]() mutable { __f(std::move(__args)...); }; - std::function funcPtr = std::move(boundFunc); + std::packaged_task* funcPtr = new std::packaged_task(std::move(boundFunc)); #ifdef _WIN32 - handle_ = (HANDLE)_beginthreadex(nullptr, 0, thread_func, new std::function(std::move(funcPtr)), 0, nullptr); + handle_ = (HANDLE)_beginthreadex(nullptr, 0, thread_func, funcPtr, 0, nullptr); #elif __linux__ pthread_create(&handle_, NULL, thread_func, funcPtr); #endif - }*/ + } ~Thread(); void join() {