X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=26aed392fd34bf1977eb7f1edf7366ffbad67787;hp=c5690a02634885f5abdf69171660317a45721bbf;hb=eb50793cffd8ac059450a76760e2c3f8ae9cc931;hpb=c9dcda6ac488c0058ebd567e1f52e30b8cd0db20 diff --git a/src/thread.h b/src/thread.h index c5690a02..26aed392 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 { @@ -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,7 +117,6 @@ 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, Depth depth, int moveCount, MovePicker* movePicker, int nodeType, bool cutNode); @@ -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;