X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=f8e65941f0d6beefa96a95aecc6195117978cca5;hp=606f96262dd72ead3f3672a45c1148f840efcb97;hb=38112060dc2da351c6dde8f12d0ee5cfaeac5084;hpb=098f645d26675bcf2180b290be77fe64a63de3ae diff --git a/src/thread.h b/src/thread.h index 606f9626..f8e65941 100644 --- a/src/thread.h +++ b/src/thread.h @@ -20,6 +20,7 @@ #ifndef THREAD_H_INCLUDED #define THREAD_H_INCLUDED +#include #include #include #include @@ -38,6 +39,19 @@ const size_t MAX_THREADS = 128; const size_t MAX_SPLITPOINTS_PER_THREAD = 8; const size_t MAX_SLAVES_PER_SPLITPOINT = 4; +/// Spinlock class wraps low level atomic operations to provide spin lock functionality + +class Spinlock { + + std::atomic_flag lock; + +public: + Spinlock() { std::atomic_flag_clear(&lock); } + void acquire() { while (lock.test_and_set(std::memory_order_acquire)) {} } + void release() { lock.clear(std::memory_order_release); } +}; + + /// SplitPoint struct stores information shared by the threads searching in /// parallel below the same split point. It is populated at splitting time. @@ -57,7 +71,7 @@ struct SplitPoint { SplitPoint* parentSplitPoint; // Shared variable data - std::mutex mutex; + Spinlock spinlock; std::bitset slavesMask; volatile bool allSlavesSearching; volatile uint64_t nodes; @@ -148,7 +162,7 @@ struct ThreadPool : public std::vector { void start_thinking(const Position&, const Search::LimitsType&, Search::StateStackPtr&); Depth minimumSplitDepth; - std::mutex mutex; + Spinlock spinlock; std::condition_variable sleepCondition; TimerThread* timer; };