blob: dcb7a1397b1e3e1a174e42f1aeb71e2fc65a70da (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
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 */
|
