summaryrefslogtreecommitdiff
path: root/src/thread-pool.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/thread-pool.hpp')
-rw-r--r--src/thread-pool.hpp25
1 files changed, 25 insertions, 0 deletions
diff --git a/src/thread-pool.hpp b/src/thread-pool.hpp
new file mode 100644
index 0000000..dcb7a13
--- /dev/null
+++ b/src/thread-pool.hpp
@@ -0,0 +1,25 @@
+#ifndef PKE_THREADING_HPP
+#define PKE_THREADING_HPP
+
+#include "dynamic-array.hpp"
+#include "pk.h"
+
+#include <cstdint>
+#include <future>
+
+struct ThreadPoolHandle : public pk_handle { };
+
+constexpr ThreadPoolHandle ThreadPoolHandle_MAX = ThreadPoolHandle{ pk_handle_MAX_constexpr };
+
+void PkeThreads_Init();
+ThreadPoolHandle PkeThreads_Init (uint8_t threadCount, uint8_t maxQueueCount, struct pk_membucket *bkt = nullptr);
+void PkeThreads_Reset (ThreadPoolHandle handle);
+bool PkeThreads_Enqueue (ThreadPoolHandle handle, std::packaged_task<void()> *job);
+int64_t PkeThreads_GetQueueCount (ThreadPoolHandle handle);
+void PkeThreads_Pause (ThreadPoolHandle handle);
+void PkeThreads_Resume (ThreadPoolHandle handle);
+void PkeThreads_Shutdown (ThreadPoolHandle handle);
+void PkeThreads_Teardown ();
+void PkeThreads_Teardown (ThreadPoolHandle handle);
+
+#endif /* PKE_THREADING_HPP */