X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=e6a4cf95744ca0260f2ae11fd7c58aa7a1dae169;hp=6744ef310b06617a5ee6d5b3308efa3d3b7a9524;hb=3aa471f2a9cb;hpb=41561c9bb80a176f9fce169975fcb553340499fc diff --git a/src/thread.h b/src/thread.h index 6744ef31..e6a4cf95 100644 --- a/src/thread.h +++ b/src/thread.h @@ -47,7 +47,6 @@ struct SplitPoint { MovePicker* mp; SplitPoint* parent; - // Shared data Lock lock; volatile uint64_t slavesMask; @@ -70,14 +69,17 @@ class Thread { Thread(const Thread&); // Only declared to disable the default ones Thread& operator=(const Thread&); // that are not suitable in this case. + typedef void (Thread::* Fn) (); + public: - Thread(int id); + Thread(Fn fn); ~Thread(); void wake_up(); bool cutoff_occurred() const; bool is_available_to(int master) const; void idle_loop(SplitPoint* sp_master); + void idle_loop() { idle_loop(NULL); } // Hack to allow storing in start_fn void main_loop(); void timer_loop(); void wait_for_stop_or_ponderhit(); @@ -89,7 +91,8 @@ public: int maxPly; Lock sleepLock; WaitCondition sleepCond; - ThreadHandle handle; + NativeHandle handle; + Fn start_fn; SplitPoint* volatile curSplitPoint; volatile int splitPointsCnt; volatile bool is_searching; @@ -108,22 +111,22 @@ class ThreadsManager { static storage duration are automatically set to zero before enter main() */ public: - void init(); - void exit(); + void init(); // No c'tor becuase Threads is static and we need stuff initialized + ~ThreadsManager(); Thread& operator[](int id) { return *threads[id]; } bool use_sleeping_threads() const { return useSleepingThreads; } int min_split_depth() const { return minimumSplitDepth; } int size() const { return (int)threads.size(); } - void wake_up(); - void sleep(); + void wake_up() const; + void sleep() const; void read_uci_options(); bool available_slave_exists(int master) const; void set_timer(int msec); - void stop_thinking(); - void start_thinking(const Position& pos, const Search::LimitsType& limits, - const std::set& = std::set(), bool async = false); + void wait_for_search_finished(); + void start_searching(const Position& pos, const Search::LimitsType& limits, + const std::set& = std::set(), bool async = false); template Value split(Position& pos, Search::Stack* ss, Value alpha, Value beta, Value bestValue, Move* bestMove,