From 55c518b2922a2d8a41212a952a68c17c7c9a3f8b Mon Sep 17 00:00:00 2001 From: Jonathan Bradley Date: Thu, 5 Jun 2025 10:50:24 -0400 Subject: pk.h: update to 0.6.0 + handle breaking changes --- src/thread-pool.cpp | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/thread-pool.cpp') diff --git a/src/thread-pool.cpp b/src/thread-pool.cpp index 5bd61c5..f110e42 100644 --- a/src/thread-pool.cpp +++ b/src/thread-pool.cpp @@ -123,7 +123,7 @@ void inline PkeThreads_Shutdown_Inner(ThreadPool &tp) { } void PkeThreads_Init() { - new (&thrdpl_mstr.bc) pk_bkt_arr_t; + new (&thrdpl_mstr.bc) pk_bkt_arr_t{ pk_bkt_arr_handle_MAX_constexpr }; } ThreadPoolHandle PkeThreads_Init(uint8_t threadCount, uint8_t maxQueueCount, struct pk_membucket *bkt) { @@ -165,7 +165,7 @@ bool PkeThreads_Enqueue(ThreadPoolHandle handle, std::packaged_task *job * Technically speaking, if we call the right pk_delete * we don't even need to worry about passing the struct pk_membucket */ - assert(pk_memory_is_in_bucket(job, tp->bkt) == true && "cannot enqueue packaged task from a non-matching struct pk_membucket"); + assert(pk_mem_bucket_ptr_is_in_mem_bucket(job, tp->bkt) == true && "cannot enqueue packaged task from a non-matching struct pk_membucket"); } return PkeThreads_Enqueue_Inner(*tp, job); -- cgit v1.2.3