X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=73be23f108c509e8a23bd0c05c322a771d7b66c3;hp=9b0a8bcf7965d42ba2e226d43a894b06afcb1b63;hb=960a689769cb143afa364d3669940c18d0c3a503;hpb=a56322fde813094afd8ffa60d12761f94e0bd3ef diff --git a/src/thread.h b/src/thread.h index 9b0a8bcf..73be23f1 100644 --- a/src/thread.h +++ b/src/thread.h @@ -20,7 +20,6 @@ #if !defined(THREAD_H_INCLUDED) #define THREAD_H_INCLUDED -#include #include #include "material.h" @@ -32,6 +31,8 @@ const int MAX_THREADS = 32; const int MAX_SPLITPOINTS_PER_THREAD = 8; +class Thread; + struct SplitPoint { // Const data after split point has been setup @@ -40,7 +41,7 @@ struct SplitPoint { Depth depth; Value beta; int nodeType; - int master; + Thread* master; Move threatMove; // Const pointers to shared data @@ -77,7 +78,7 @@ public: void wake_up(); bool cutoff_occurred() const; - bool is_available_to(int master) const; + bool is_available_to(Thread* master) const; void idle_loop(SplitPoint* sp_master); void idle_loop() { idle_loop(NULL); } // Hack to allow storing in start_fn void main_loop(); @@ -85,9 +86,9 @@ public: void wait_for_stop_or_ponderhit(); SplitPoint splitPoints[MAX_SPLITPOINTS_PER_THREAD]; - MaterialInfoTable materialTable; - PawnInfoTable pawnTable; - int threadID; + MaterialTable materialTable; + PawnTable pawnTable; + int idx; int maxPly; Lock sleepLock; WaitCondition sleepCond; @@ -101,32 +102,33 @@ public: }; -/// ThreadsManager class handles all the threads related stuff like init, starting, +/// ThreadPool class handles all the threads related stuff like init, starting, /// parking and, the most important, launching a slave thread at a split point. /// All the access to shared thread data is done through this class. -class ThreadsManager { - /* As long as the single ThreadsManager object is defined as a global we don't +class ThreadPool { + /* As long as the single ThreadPool object is defined as a global we don't need to explicitly initialize to zero its data members because variables with static storage duration are automatically set to zero before enter main() */ public: - void init(); // No c'tor becuase Threads is static and we need stuff initialized - ~ThreadsManager(); + void init(); // No c'tor becuase Threads is global and we need engine initialized + ~ThreadPool(); 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(); } + Thread* main_thread() { return threads[0]; } void wake_up() const; void sleep() const; void read_uci_options(); - bool available_slave_exists(int master) const; + bool available_slave_exists(Thread* master) const; void set_timer(int msec); void wait_for_search_finished(); void start_searching(const Position& pos, const Search::LimitsType& limits, - const std::set& = std::set()); + const std::vector& searchMoves); template Value split(Position& pos, Search::Stack* ss, Value alpha, Value beta, Value bestValue, Move* bestMove, @@ -143,6 +145,6 @@ private: bool useSleepingThreads; }; -extern ThreadsManager Threads; +extern ThreadPool Threads; #endif // !defined(THREAD_H_INCLUDED)