From 3583af4e1c7979e8d309693d53fbe9184e067a50 Mon Sep 17 00:00:00 2001 From: Jonathan Bradley Date: Wed, 27 Aug 2025 17:19:24 -0400 Subject: pk.h: update to 0.9.0, handle breaking changes --- src/thread-pool.cpp | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'src/thread-pool.cpp') 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 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{ 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{ 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); } -- cgit v1.2.3