X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=96ad121efeec2632ef85cf033b22497f3cadc832;hp=12fc4f23a70e1c21d596f092b9b0a35932c0e9b8;hb=4e619a13d6671db198bc9c39d54dd7f243ef5873;hpb=673bc5526fa3d352f823ad144fb521b5dc98f45c diff --git a/src/thread.h b/src/thread.h index 12fc4f23..96ad121e 100644 --- a/src/thread.h +++ b/src/thread.h @@ -67,20 +67,16 @@ struct SplitPoint { 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) (); + typedef void (Thread::* Fn) (); // Pointer to member function public: Thread(Fn fn); - ~Thread(); + ~Thread(); void wake_up(); bool cutoff_occurred() const; - bool is_available_to(const Thread& master) const; - void idle_loop(SplitPoint* sp_master); - void idle_loop() { idle_loop(NULL); } // Hack to allow storing in start_fn + bool is_available_to(Thread* master) const; + void idle_loop(); void main_loop(); void timer_loop(); void wait_for_stop_or_ponderhit(); @@ -88,7 +84,7 @@ public: SplitPoint splitPoints[MAX_SPLITPOINTS_PER_THREAD]; MaterialTable materialTable; PawnTable pawnTable; - int idx; + size_t idx; int maxPly; Lock sleepLock; WaitCondition sleepCond; @@ -102,29 +98,26 @@ 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 - need to explicitly initialize to zero its data members because variables with - static storage duration are automatically set to zero before enter main() - */ +class ThreadPool { + public: - void init(); // No c'tor becuase Threads is static and we need engine initialized - ~ThreadsManager(); + void init(); // No c'tor, Threads object is global and engine shall be fully 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(); } + size_t size() const { return threads.size(); } Thread* main_thread() { return threads[0]; } void wake_up() const; void sleep() const; void read_uci_options(); - bool available_slave_exists(const Thread& 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, @@ -145,6 +138,6 @@ private: bool useSleepingThreads; }; -extern ThreadsManager Threads; +extern ThreadPool Threads; #endif // !defined(THREAD_H_INCLUDED)