X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=ad40a34146bbd8e8b8fe0f80be4dcc23b5dd7d44;hp=c39c6e695e9fc7947a9b3a89fb7aad655c61e5d9;hb=7a2825053e3eb5204e6b45d0cadb9264e77ac69f;hpb=e1919384a23fe728422f995369161efa192380db diff --git a/src/thread.h b/src/thread.h index c39c6e69..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,26 +98,21 @@ 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(); } - Thread* main_thread() const { return threads[0]; } - Thread* this_thread() const { return (Thread*)tls_get(tlsKey); } - void set_this_thread(Thread* th) const { tls_set(tlsKey, th); } + size_t size() const { return threads.size(); } + Thread* main_thread() { return threads[0]; } void wake_up() const; void sleep() const; @@ -140,7 +131,6 @@ private: std::vector threads; Thread* timer; - ThreadLocalStorageKey tlsKey; Lock splitLock; WaitCondition sleepCond; Depth minimumSplitDepth; @@ -148,6 +138,6 @@ private: bool useSleepingThreads; }; -extern ThreadsManager Threads; +extern ThreadPool Threads; #endif // !defined(THREAD_H_INCLUDED)