src/thread_pool.hpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

#ifndef PKE_THREADING_HPP
#define PKE_THREADING_HPP

#include "dynamic-array.hpp"
#include "macros.hpp"

#include <atomic>
#include <condition_variable>
#include <cstdint>
#include <future>

TypeSafeInt_H(ThreadPoolHandle, uint64_t, 0xFFFFFFFFFFFFFFFF);

ThreadPoolHandle PkeThreads_Init     (uint8_t threadCount, uint8_t maxQueueCount, MemBucket *bkt = nullptr);
void             PkeThreads_Reset    (ThreadPoolHandle handle);
bool             PkeThreads_Enqueue  (ThreadPoolHandle handle, std::packaged_task<void()> job);
void             PkeThreads_Pause    (ThreadPoolHandle handle);
void             PkeThreads_Resume   (ThreadPoolHandle handle);
void             PkeThreads_Shutdown (ThreadPoolHandle handle);
void             PkeThreads_Teardown (ThreadPoolHandle handle);

#endif /* PKE_THREADING_HPP */