tiamak/p2pool-salvium-stare
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed parallel_run logic on single CPU systems

Browse Source
This commit is contained in:
SChernykh
2023-03-17 16:01:52 +01:00
parent 146d29b627
commit 6baf5247cb
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/uv_util.h
+8 -7
View File
@@ -179,16 +179,17 @@ bool CallOnLoop(uv_loop_t* loop, T&& callback)
template<typename T> template<typename T>
void parallel_run(uv_loop_t* loop, T&& callback, bool wait = false) void parallel_run(uv_loop_t* loop, T&& callback, bool wait = false)
{ {
uint32_t THREAD_COUNT = std::thread::hardware_concurrency(); const uint32_t THREAD_COUNT = std::thread::hardware_concurrency();
if (THREAD_COUNT > 0) { // Don't start other threads on single CPU systems
--THREAD_COUNT; if (THREAD_COUNT <= 1) {
callback();
return;
} }
// "THREAD_COUNT - 1" because current thread is already running
// No more than 8 threads because our UV worker thread pool has 8 threads // No more than 8 threads because our UV worker thread pool has 8 threads
if (THREAD_COUNT > 8) { const uint32_t THREADS_TO_START = std::min<uint32_t>(THREAD_COUNT - 1, 8);
THREAD_COUNT = 8;
}
struct Callback struct Callback
{ {
@@ -206,7 +207,7 @@ void parallel_run(uv_loop_t* loop, T&& callback, bool wait = false)
std::shared_ptr<Callback> cb; std::shared_ptr<Callback> cb;
}; };
for (size_t i = 0; i < THREAD_COUNT; ++i) { for (size_t i = 0; i < THREADS_TO_START; ++i) {
Work* w = new Work{ {}, cb }; Work* w = new Work{ {}, cb };
w->req.data = w; w->req.data = w;