summaryrefslogtreecommitdiff
path: root/src/thread-pool.cpp
diff options
context:
space:
mode:
authorJonathan Bradley <jcb@pikum.xyz>2025-06-05 10:50:24 -0400
committerJonathan Bradley <jcb@pikum.xyz>2025-06-05 10:50:24 -0400
commit55c518b2922a2d8a41212a952a68c17c7c9a3f8b (patch)
tree31cc135bc18bf11893d5ca3bca47c9ee27bf141f /src/thread-pool.cpp
parentb0b1159780311c7c8ca9a9d41d11794e91e8895c (diff)
pk.h: update to 0.6.0 + handle breaking changes
Diffstat (limited to 'src/thread-pool.cpp')
-rw-r--r--src/thread-pool.cpp4
1 files changed, 2 insertions, 2 deletions
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<ThreadPool>;
+ new (&thrdpl_mstr.bc) pk_bkt_arr_t<ThreadPool>{ 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<void()> *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);