X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=src%2Fthread.h;h=6744ef310b06617a5ee6d5b3308efa3d3b7a9524;hb=41561c9bb80a176f9fce169975fcb553340499fc;hp=e71db835734d7bd2bc146b0cf71332e0d9b6ca61;hpb=b356e0fae3b78e39af2ae8aca6ca6197e8669819;p=stockfish diff --git a/src/thread.h b/src/thread.h index e71db835..6744ef31 100644 --- a/src/thread.h +++ b/src/thread.h @@ -21,6 +21,7 @@ #define THREAD_H_INCLUDED #include +#include #include "material.h" #include "movepick.h" @@ -64,7 +65,14 @@ struct SplitPoint { /// tables so that once we get a pointer to an entry its life time is unlimited /// and we don't have to care about someone changing the entry under our feet. -struct Thread { +class Thread { + + Thread(const Thread&); // Only declared to disable the default ones + Thread& operator=(const Thread&); // that are not suitable in this case. + +public: + Thread(int id); + ~Thread(); void wake_up(); bool cutoff_occurred() const; @@ -100,15 +108,16 @@ class ThreadsManager { static storage duration are automatically set to zero before enter main() */ public: - Thread& operator[](int threadID) { return threads[threadID]; } void init(); void exit(); + 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 activeThreads; } + int size() const { return (int)threads.size(); } - void set_size(int cnt); + void wake_up(); + void sleep(); void read_uci_options(); bool available_slave_exists(int master) const; void set_timer(int msec); @@ -120,14 +129,14 @@ public: Value split(Position& pos, Search::Stack* ss, Value alpha, Value beta, Value bestValue, Move* bestMove, Depth depth, Move threatMove, int moveCount, MovePicker* mp, int nodeType); private: - friend struct Thread; + friend class Thread; - Thread threads[MAX_THREADS + 1]; // Last one is used as a timer + std::vector threads; + Thread* timer; Lock splitLock; WaitCondition sleepCond; Depth minimumSplitDepth; int maxThreadsPerSplitPoint; - int activeThreads; bool useSleepingThreads; };