diff options
| author | Jonathan Bradley <jcb@pikum.xyz> | 2025-06-05 10:50:24 -0400 |
|---|---|---|
| committer | Jonathan Bradley <jcb@pikum.xyz> | 2025-06-05 10:50:24 -0400 |
| commit | 55c518b2922a2d8a41212a952a68c17c7c9a3f8b (patch) | |
| tree | 31cc135bc18bf11893d5ca3bca47c9ee27bf141f /src/thread-pool.cpp | |
| parent | b0b1159780311c7c8ca9a9d41d11794e91e8895c (diff) | |
pk.h: update to 0.6.0 + handle breaking changes
Diffstat (limited to 'src/thread-pool.cpp')
| -rw-r--r-- | src/thread-pool.cpp | 4 |
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); |
