X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=8a512c96dd22f5fa84f04c1733c45ccf4fb6b38c;hp=c5690a02634885f5abdf69171660317a45721bbf;hb=79232be02a03a5e2225b30f843e9597fd85951dc;hpb=c9dcda6ac488c0058ebd567e1f52e30b8cd0db20 diff --git a/src/thread.h b/src/thread.h index c5690a02..8a512c96 100644 --- a/src/thread.h +++ b/src/thread.h @@ -20,6 +20,7 @@ #ifndef THREAD_H_INCLUDED #define THREAD_H_INCLUDED +#include #include #include "material.h" @@ -28,7 +29,7 @@ #include "position.h" #include "search.h" -const int MAX_THREADS = 64; // Because SplitPoint::slavesMask is a uint64_t +const int MAX_THREADS = 128; const int MAX_SPLITPOINTS_PER_THREAD = 8; struct Mutex { @@ -62,7 +63,7 @@ struct SplitPoint { // Const data after split point has been setup const Position* pos; - const Search::Stack* ss; + Search::Stack* ss; Thread* masterThread; Depth depth; Value beta; @@ -75,8 +76,9 @@ struct SplitPoint { // Shared data Mutex mutex; - volatile uint64_t slavesMask; - volatile int64_t nodes; + std::bitset slavesMask; + volatile bool allSlavesSearching; + volatile uint64_t nodes; volatile Value alpha; volatile Value bestValue; volatile Move bestMove; @@ -90,7 +92,7 @@ struct SplitPoint { struct ThreadBase { - ThreadBase() : exit(false) {} + ThreadBase() : handle(NativeHandle()), exit(false) {} virtual ~ThreadBase() {} virtual void idle_loop() = 0; void notify_one(); @@ -115,8 +117,7 @@ struct Thread : public ThreadBase { bool cutoff_occurred() const; bool available_to(const Thread* master) const; - template - void split(Position& pos, const Search::Stack* ss, Value alpha, Value beta, Value* bestValue, Move* bestMove, + void split(Position& pos, Search::Stack* ss, Value alpha, Value beta, Value* bestValue, Move* bestMove, Depth depth, int moveCount, MovePicker* movePicker, int nodeType, bool cutNode); SplitPoint splitPoints[MAX_SPLITPOINTS_PER_THREAD]; @@ -162,12 +163,9 @@ struct ThreadPool : public std::vector { void read_uci_options(); Thread* available_slave(const Thread* master) const; void wait_for_think_finished(); - void start_thinking(const Position&, const Search::LimitsType&, - const std::vector&, Search::StateStackPtr&); + void start_thinking(const Position&, const Search::LimitsType&, Search::StateStackPtr&); - bool sleepWhileIdle; Depth minimumSplitDepth; - size_t maxThreadsPerSplitPoint; Mutex mutex; ConditionVariable sleepCondition; TimerThread* timer;