tri11paragon
/
BLT
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

thread class needs some work. use the constructor if non-queue

v1
Brett 2024-01-01 20:53:26 -05:00
parent 6e51e5cbe6
commit f960dbddae
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
include/blt/std/thread.h
View File

@ -28,6 +28,7 @@
#include <atomic> #include <atomic>
#include <mutex> #include <mutex>
#include <chrono> #include <chrono>
#include <optional>
namespace blt namespace blt
{ {
@ -46,8 +47,10 @@ namespace blt
std::variant<std::queue<thread_function>, thread_function> func_queue; std::variant<std::queue<thread_function>, thread_function> func_queue;
std::mutex queue_mutex; std::mutex queue_mutex;
public: public:
explicit thread_pool(std::uint64_t number_of_threads = 8) explicit thread_pool(std::uint64_t number_of_threads = 8, std::optional<thread_function> default_function = {})
{ {
if (default_function.has_value())
func_queue = default_function.value();
this->number_of_threads = number_of_threads; this->number_of_threads = number_of_threads;
for (std::uint64_t i = 0; i < number_of_threads; i++) for (std::uint64_t i = 0; i < number_of_threads; i++)
{ {
@ -77,7 +80,8 @@ namespace blt
if (std::holds_alternative<std::queue<thread_function>>(func_queue)) if (std::holds_alternative<std::queue<thread_function>>(func_queue))
{ {
std::this_thread::sleep_for(std::chrono::milliseconds(16)); std::this_thread::sleep_for(std::chrono::milliseconds(16));
continue; BLT_WARN("Running non queue variant with a queue inside!");
break;
} }
} }
auto& func = std::get<thread_function>(func_queue); auto& func = std::get<thread_function>(func_queue);