X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.h;h=afae57c3a9b02e7b265584e1cc56e65cc82704f1;hp=fd7343a8f57a1d9d2bc0f1c40f27c94ad1148098;hb=9eceb894ac91b9b4a88d1972778705304666ac33;hpb=27c5cb59127101d834636d4faa0062d4e7bd05ce diff --git a/src/thread.h b/src/thread.h index fd7343a8..afae57c3 100644 --- a/src/thread.h +++ b/src/thread.h @@ -2,6 +2,7 @@ Stockfish, a UCI chess playing engine derived from Glaurung 2.1 Copyright (C) 2004-2008 Tord Romstad (Glaurung author) Copyright (C) 2008-2015 Marco Costalba, Joona Kiiski, Tord Romstad + Copyright (C) 2015-2016 Marco Costalba, Joona Kiiski, Gary Linscott, 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 @@ -35,41 +36,32 @@ #include "thread_win32.h" -/// ThreadBase struct is the base of the hierarchy from where we derive all the -/// specialized thread classes. +/// Thread struct keeps together all the thread related stuff. We also use +/// per-thread pawn and material hash 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 ThreadBase : public std::thread { - - ThreadBase() { exit = false; } - virtual ~ThreadBase() = default; - virtual void idle_loop() = 0; - void notify_one(); - void wait(std::atomic& b); - void wait_while(std::atomic& b); +class Thread { + std::thread nativeThread; Mutex mutex; ConditionVariable sleepCondition; - std::atomic exit; -}; - - -/// Thread struct keeps together all the thread related stuff like locks, state, -/// history and countermoves tables. We also use per-thread pawn and material hash -/// 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 : public ThreadBase { + bool exit, searching; +public: Thread(); - virtual void idle_loop(); - void search(bool isMainThread = false); + virtual ~Thread(); + virtual void search(); + void idle_loop(); + void start_searching(bool resume = false); + void wait_for_search_finished(); + void wait(std::atomic_bool& b); Pawns::Table pawnsTable; Material::Table materialTable; Endgames endgames; size_t idx, PVIdx; - int maxPly; - std::atomic searching; + int maxPly, callsCnt; Position rootPos; Search::RootMoveVector rootMoves; @@ -77,45 +69,34 @@ struct Thread : public ThreadBase { HistoryStats history; MovesStats counterMoves; Depth completedDepth; + std::atomic_bool resetCalls; }; -/// MainThread and TimerThread are derived classes used to characterize the two -/// special threads: the main one and the recurring timer. +/// MainThread is a derived class with a specific overload for the main thread struct MainThread : public Thread { - MainThread() { thinking = true; } // Avoid a race with start_thinking() - virtual void idle_loop(); - void join(); - void think(); - std::atomic thinking; -}; + virtual void search(); -struct TimerThread : public ThreadBase { - - static const int Resolution = 5; // Millisec between two check_time() calls - - virtual void idle_loop(); - void check_time(); - - bool run = false; + bool easyMovePlayed, failedLow; + double bestMoveChanges; + Value previousMoveScore; }; /// ThreadPool struct handles all the threads related stuff like init, starting, -/// parking and, most importantly, launching a thread. -/// All the access to shared thread data is done through this class. +/// parking and, most importantly, launching a thread. All the access to threads +/// data is done through this class. struct ThreadPool : public std::vector { - void init(); // No constructor and destructor, threads rely on globals that should + void init(); // No constructor and destructor, threads rely on globals that should void exit(); // be initialized and valid during the whole thread lifetime. MainThread* main() { return static_cast(at(0)); } - void read_uci_options(); void start_thinking(const Position&, const Search::LimitsType&, Search::StateStackPtr&); + void read_uci_options(); int64_t nodes_searched(); - TimerThread* timer; }; extern ThreadPool Threads;