X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.cpp;h=4c582e08d54645933dd2b8bd627938259faa2f5f;hp=9c132a03abf3250532593ac7b818ba325d1be524;hb=8307da0de77c9c7bbf7c56a7d9c8a688ff4dfb4e;hpb=3f14ed6602936ecf98b0a26c5abc1c980a091f63 diff --git a/src/thread.cpp b/src/thread.cpp index 9c132a03..4c582e08 100644 --- a/src/thread.cpp +++ b/src/thread.cpp @@ -1,7 +1,7 @@ /* Stockfish, a UCI chess playing engine derived from Glaurung 2.1 Copyright (C) 2004-2008 Tord Romstad (Glaurung author) - Copyright (C) 2008-2010 Marco Costalba, Joona Kiiski, Tord Romstad + Copyright (C) 2008-2012 Marco Costalba, Joona Kiiski, Tord Romstad Stockfish is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -112,11 +112,11 @@ bool Thread::is_available_to(int master) const { void ThreadsManager::read_uci_options() { - maxThreadsPerSplitPoint = Options["Maximum Number of Threads per Split Point"].value(); - minimumSplitDepth = Options["Minimum Split Depth"].value() * ONE_PLY; - useSleepingThreads = Options["Use Sleeping Threads"].value(); + maxThreadsPerSplitPoint = Options["Max Threads per Split Point"]; + minimumSplitDepth = Options["Min Split Depth"] * ONE_PLY; + useSleepingThreads = Options["Use Sleeping Threads"]; - set_size(Options["Threads"].value()); + set_size(Options["Threads"]); } @@ -197,7 +197,7 @@ void ThreadsManager::exit() { for (int i = 0; i <= MAX_THREADS; i++) { - threads[i].do_terminate = true; + threads[i].do_terminate = true; // Search must be already finished threads[i].wake_up(); // Wait for thread termination @@ -443,7 +443,7 @@ void ThreadsManager::start_thinking(const Position& pos, const LimitsType& limit // Copy input arguments to initialize the search RootPosition.copy(pos, 0); Limits = limits; - RootMoves = searchMoves; + SearchMoves = searchMoves; // Reset signals before to start the new search memset((void*)&Signals, 0, sizeof(Signals)); @@ -458,6 +458,27 @@ void ThreadsManager::start_thinking(const Position& pos, const LimitsType& limit } +// ThreadsManager::stop_thinking() is used by UI thread to raise a stop request +// and to wait for the main thread finishing the search. Needed to wait exiting +// and terminate the threads after a 'quit' command. + +void ThreadsManager::stop_thinking() { + + Thread& main = threads[0]; + + Search::Signals.stop = true; + + lock_grab(&main.sleepLock); + + cond_signal(&main.sleepCond); // In case is waiting for stop or ponderhit + + while (!main.do_sleep) + cond_wait(&sleepCond, &main.sleepLock); + + lock_release(&main.sleepLock); +} + + // ThreadsManager::wait_for_stop_or_ponderhit() is called when the maximum depth // is reached while the program is pondering. The point is to work around a wrinkle // in the UCI protocol: When pondering, the engine is not allowed to give a