X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.cpp;h=65e170a0628b51dd4a1a3f0e20fc5c94d6628241;hp=440b8bf0e4f06b5ea6087aa76c2e9aec3ca02cc0;hb=8765f9ce168b129b3283fc1e458eae2f8871b1d4;hpb=89723339d93c87f52e148080d5b1dc101ee76685 diff --git a/src/thread.cpp b/src/thread.cpp index 440b8bf0..65e170a0 100644 --- a/src/thread.cpp +++ b/src/thread.cpp @@ -25,8 +25,7 @@ #include "search.h" #include "thread.h" #include "uci.h" - -using namespace Search; +#include "syzygy/tbprobe.h" ThreadPool Threads; // Global object @@ -37,6 +36,7 @@ Thread::Thread() { resetCalls = exit = false; maxPly = callsCnt = 0; + tbHits = 0; history.clear(); counterMoves.clear(); idx = Threads.size(); // Start from 0 @@ -96,6 +96,8 @@ void Thread::start_searching(bool resume) { void Thread::idle_loop() { + WinProcGroup::bindThisThread(idx); + while (!exit) { std::unique_lock lk(mutex); @@ -159,38 +161,65 @@ void ThreadPool::read_uci_options() { /// ThreadPool::nodes_searched() returns the number of nodes searched -int64_t ThreadPool::nodes_searched() { +uint64_t ThreadPool::nodes_searched() const { - int64_t nodes = 0; + uint64_t nodes = 0; for (Thread* th : *this) nodes += th->rootPos.nodes_searched(); return nodes; } +/// ThreadPool::tb_hits() returns the number of TB hits + +uint64_t ThreadPool::tb_hits() const { + + uint64_t hits = 0; + for (Thread* th : *this) + hits += th->tbHits; + return hits; +} + + /// ThreadPool::start_thinking() wakes up the main thread sleeping in idle_loop() /// and starts a new search, then returns immediately. -void ThreadPool::start_thinking(const Position& pos, const LimitsType& limits, - StateStackPtr& states) { +void ThreadPool::start_thinking(Position& pos, StateListPtr& states, + const Search::LimitsType& limits) { main()->wait_for_search_finished(); - Signals.stopOnPonderhit = Signals.stop = false; - - main()->rootMoves.clear(); - main()->rootPos = pos; - Limits = limits; - if (states.get()) // If we don't set a new position, preserve current state - { - SetupStates = std::move(states); // Ownership transfer here - assert(!states.get()); - } + Search::Signals.stopOnPonderhit = Search::Signals.stop = false; + Search::Limits = limits; + Search::RootMoves rootMoves; for (const auto& m : MoveList(pos)) if ( limits.searchmoves.empty() || std::count(limits.searchmoves.begin(), limits.searchmoves.end(), m)) - main()->rootMoves.push_back(RootMove(m)); + rootMoves.push_back(Search::RootMove(m)); + + if (!rootMoves.empty()) + Tablebases::filter_root_moves(pos, rootMoves); + + // After ownership transfer 'states' becomes empty, so if we stop the search + // and call 'go' again without setting a new position states.get() == NULL. + assert(states.get() || setupStates.get()); + + if (states.get()) + setupStates = std::move(states); // Ownership transfer, states is now empty + + StateInfo tmp = setupStates->back(); + + for (Thread* th : Threads) + { + th->maxPly = 0; + th->tbHits = 0; + th->rootDepth = DEPTH_ZERO; + th->rootMoves = rootMoves; + th->rootPos.set(pos.fen(), pos.is_chess960(), &setupStates->back(), th); + } + + setupStates->back() = tmp; // Restore st->previous, cleared by Position::set() main()->start_searching(); }