diff options
Diffstat (limited to 'src/thread-pool.cpp')
| -rw-r--r-- | src/thread-pool.cpp | 5 |
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); } |
