X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=26aed392fd34bf1977eb7f1edf7366ffbad67787;hp=8169407e09b0766e7d4edb4d556727a6b5b2ea17;hb=eb50793cffd8ac059450a76760e2c3f8ae9cc931;hpb=f5727deee3823accf791984836f45db78e3a53e5 diff --git a/src/thread.h b/src/thread.h index 8169407e..26aed392 100644 --- a/src/thread.h +++ b/src/thread.h @@ -1,7 +1,7 @@ /* Stockfish, a UCI chess playing engine derived from Glaurung 2.1 Copyright (C) 2004-2008 Tord Romstad (Glaurung author) - Copyright (C) 2008-2013 Marco Costalba, Joona Kiiski, Tord Romstad + Copyright (C) 2008-2014 Marco Costalba, Joona Kiiski, Tord Romstad Stockfish is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -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;