From 14c2c1395b2d3e4e766b1ace71a486432259da73 Mon Sep 17 00:00:00 2001 From: Marco Costalba Date: Wed, 6 Feb 2013 09:36:13 +0100 Subject: [PATCH] Change slave_available() API To return a pointer to the available thread instead of a bool. This allows to simplify the core loop in split(). No functional change. Signed-off-by: Marco Costalba --- src/search.cpp | 2 +- src/thread.cpp | 23 ++++++++++------------- src/thread.h | 2 +- 3 files changed, 12 insertions(+), 15 deletions(-) diff --git a/src/search.cpp b/src/search.cpp index ec457609..60b7c806 100644 --- a/src/search.cpp +++ b/src/search.cpp @@ -1025,7 +1025,7 @@ split_point_start: // At split points actual search starts from here // Step 19. Check for splitting the search if ( !SpNode && depth >= Threads.minimumSplitDepth - && Threads.slave_available(thisThread) + && Threads.available_slave(thisThread) && thisThread->splitPointsSize < MAX_SPLITPOINTS_PER_THREAD) { assert(bestValue < beta); diff --git a/src/thread.cpp b/src/thread.cpp index b04b8adb..3b59a05d 100644 --- a/src/thread.cpp +++ b/src/thread.cpp @@ -229,13 +229,13 @@ void ThreadPool::read_uci_options() { // slave_available() tries to find an idle thread which is available as a slave // for the thread 'master'. -bool ThreadPool::slave_available(Thread* master) const { +Thread* ThreadPool::available_slave(Thread* master) const { for (const_iterator it = begin(); it != end(); ++it) if ((*it)->is_available_to(master)) - return true; + return *it; - return false; + return NULL; } @@ -290,18 +290,15 @@ void Thread::split(Position& pos, Stack* ss, Value alpha, Value beta, Value* bes activeSplitPoint = &sp; size_t slavesCnt = 1; // This thread is always included + Thread* slave; - for (ThreadPool::iterator it = Threads.begin(); it != Threads.end() && !Fake; ++it) + while ( (slave = Threads.available_slave(this)) != NULL + && ++slavesCnt <= Threads.maxThreadsPerSplitPoint && !Fake) { - Thread* slave = *it; - - if (slave->is_available_to(this) && ++slavesCnt <= Threads.maxThreadsPerSplitPoint) - { - sp.slavesMask |= 1ULL << slave->idx; - slave->activeSplitPoint = &sp; - slave->searching = true; // Slave leaves idle_loop() - slave->notify_one(); // Could be sleeping - } + sp.slavesMask |= 1ULL << slave->idx; + slave->activeSplitPoint = &sp; + slave->searching = true; // Slave leaves idle_loop() + slave->notify_one(); // Could be sleeping } sp.mutex.unlock(); diff --git a/src/thread.h b/src/thread.h index b18170df..c760c20d 100644 --- a/src/thread.h +++ b/src/thread.h @@ -149,7 +149,7 @@ struct ThreadPool : public std::vector { MainThread* main_thread() { return static_cast((*this)[0]); } void read_uci_options(); - bool slave_available(Thread* master) const; + Thread* available_slave(Thread* master) const; void wait_for_think_finished(); void start_thinking(const Position&, const Search::LimitsType&, const std::vector&, Search::StateStackPtr&); -- 2.39.2