summaryrefslogtreecommitdiff
path: root/src/thread-pool.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/thread-pool.cpp')
-rw-r--r--src/thread-pool.cpp5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/thread-pool.cpp b/src/thread-pool.cpp
index 68353b9..f9ff155 100644
--- a/src/thread-pool.cpp
+++ b/src/thread-pool.cpp
@@ -19,6 +19,7 @@ struct ThreadPool {
};
struct ThreadPoolMaster {
+ pk_membucket *bkt;
pk_bkt_arr_t<ThreadPool> bc{};
}thrdpl_mstr;
@@ -124,7 +125,8 @@ void inline PkeThreads_Shutdown_Inner(ThreadPool &tp) {
}
void PkeThreads_Init() {
- new (&thrdpl_mstr.bc) pk_bkt_arr_t<ThreadPool>{ pk_bkt_arr_handle_MAX_constexpr };
+ thrdpl_mstr.bkt = pk_mem_bucket_create("pk_bkt_arr threads", 1024 * 1024, PK_MEMBUCKET_FLAG_NONE);
+ new (&thrdpl_mstr.bc) pk_bkt_arr_t<ThreadPool>{ pk_bkt_arr_handle_MAX_constexpr, thrdpl_mstr.bkt, thrdpl_mstr.bkt };
}
ThreadPoolHandle PkeThreads_Init(uint8_t threadCount, uint8_t maxQueueCount, struct pk_membucket *bkt) {
@@ -215,4 +217,5 @@ void PkeThreads_Teardown(ThreadPoolHandle handle) {
void PkeThreads_Teardown() {
pk_bkt_arr_teardown(&thrdpl_mstr.bc);
+ pk_mem_bucket_destroy(thrdpl_mstr.bkt);
}