X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=src%2Fsearch.cpp;h=a97c73485523eaf13002ddf3c6895b3f7c52d663;hb=ea6c1f7a17572f1cd291ffd00e28cfbd3b2947d5;hp=b3f66c6a8001f79845ab783df4206d5a0f803071;hpb=3b14b17664b30933e55d0fb1c8248ddab8b49110;p=stockfish diff --git a/src/search.cpp b/src/search.cpp index b3f66c6a..a97c7348 100644 --- a/src/search.cpp +++ b/src/search.cpp @@ -227,7 +227,15 @@ void Search::think() { << std::endl; } - Threads.wake_up(); + // Reset and wake up the threads + for (size_t i = 0; i < Threads.size(); i++) + { + Threads[i].maxPly = 0; + Threads[i].do_sleep = false; + + if (!Threads.use_sleeping_threads()) + Threads[i].notify_one(); + } // Set best timer interval to avoid lagging under time pressure. Timer is // used to check for remaining available thinking time. @@ -242,7 +250,11 @@ void Search::think() { id_loop(RootPos); // Let's start searching ! Threads.set_timer(0); // Stop timer - Threads.sleep(); + + // Main thread will go to sleep by itself to avoid a race with start_searching() + for (size_t i = 0; i < Threads.size(); i++) + if (&Threads[i] != Threads.main_thread()) + Threads[i].do_sleep = true; if (Options["Use Search Log"]) { @@ -262,10 +274,15 @@ void Search::think() { finalize: // When we reach max depth we arrive here even without Signals.stop is raised, - // but if we are pondering or in infinite search, we shouldn't print the best - // move before we are told to do so. + // but if we are pondering or in infinite search, according to UCI protocol, + // we shouldn't print the best move before the GUI sends a "stop" or "ponderhit" + // command. We simply wait here until GUI sends one of those commands (that + // raise Signals.stop). if (!Signals.stop && (Limits.ponder || Limits.infinite)) - RootPos.this_thread()->wait_for_stop_or_ponderhit(); + { + Signals.stopOnPonderhit = true; + RootPos.this_thread()->wait_for(Signals.stop); + } // Best move could be MOVE_NONE when searching on a stalemate position sync_cout << "bestmove " << move_to_uci(RootMoves[0].pv[0], RootPos.is_chess960()) @@ -1693,7 +1710,7 @@ void Thread::idle_loop() { && !sp->slavesMask) { assert(!sp->master->is_searching); - sp->master->wake_up(); + sp->master->notify_one(); } // After releasing the lock we cannot access anymore any SplitPoint