X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=ad40a34146bbd8e8b8fe0f80be4dcc23b5dd7d44;hp=3eb8fc9cfe4d8f001a5ae8a4d4685a39cc6539f5;hb=7a2825053e3eb5204e6b45d0cadb9264e77ac69f;hpb=c2fc80e5d16339266b5bf6687fa843ff65de3b3e diff --git a/src/thread.h b/src/thread.h index 3eb8fc9c..ad40a341 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(Thread* master) const; - void idle_loop(SplitPoint* sp_master); - void idle_loop() { idle_loop(NULL); } // Hack to allow storing in start_fn + 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,23 +98,20 @@ 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]; } + Thread& operator[](size_t 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; @@ -145,6 +138,6 @@ private: bool useSleepingThreads; }; -extern ThreadsManager Threads; +extern ThreadPool Threads; #endif // !defined(THREAD_H_INCLUDED)