diff options
| author | Jonathan Bradley <jcb@pikum.xyz> | 2025-01-14 18:17:54 -0500 |
|---|---|---|
| committer | Jonathan Bradley <jcb@pikum.xyz> | 2025-01-14 18:17:54 -0500 |
| commit | 5a7b4a65a1d93744e4a5e6cc6df4244f61b81f68 (patch) | |
| tree | 4b59cb1d6e513c1caefdc7e4c35955741bcfe206 /src/thread-pool.cpp | |
| parent | 80a67230fe192287503092a3d256aea3a494409c (diff) | |
chore: fix compiler warnings + extra includes
Diffstat (limited to 'src/thread-pool.cpp')
| -rw-r--r-- | src/thread-pool.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/thread-pool.cpp b/src/thread-pool.cpp index 061ae68..b6ff97e 100644 --- a/src/thread-pool.cpp +++ b/src/thread-pool.cpp @@ -2,6 +2,7 @@ #include "thread-pool.hpp" #include "bucketed-array.hpp" +#include "dynamic-array.hpp" #include <functional> #include <future> @@ -106,8 +107,8 @@ void inline PkeThreads_Pause_Inner(ThreadPool &tp) { void inline PkeThreads_Resume_Inner(ThreadPool &tp) { tp.mutex.lock(); tp.isPaused = false; - long count = tp.threads->Count(); - for (size_t i = 0; i < count; i++) { + int64_t count = tp.threads->Count(); + for (int64_t i = 0; i < count; i++) { (*tp.threads)[i] = std::thread(std::bind(ThreadRun, &tp)); } tp.mutex.unlock(); |
