#ifndef PKE_THREADING_HPP
#define PKE_THREADING_HPP

#include "dynamic-array.hpp"
#include "vendor/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 */