X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread.cpp;h=0b851d6a6e0b5f0f48d5535aea3a06cd5c4d909d;hp=2923c07fac52ad9ac105bd318f1c059dffde17c8;hb=5410424e3d036b43715c7989aa99e449cdcde18e;hpb=8662bdfa124ae3ec90d9bf88842d9cfab9a43532 diff --git a/src/thread.cpp b/src/thread.cpp index 2923c07f..0b851d6a 100644 --- a/src/thread.cpp +++ b/src/thread.cpp @@ -2,7 +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 + Copyright (C) 2015-2017 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 @@ -34,10 +34,9 @@ ThreadPool Threads; // Global object Thread::Thread() { - resetCalls = exit = false; - maxPly = callsCnt = 0; - history.clear(); - counterMoves.clear(); + exit = false; + selDepth = 0; + nodes = tbHits = 0; idx = Threads.size(); // Start from 0 std::unique_lock lk(mutex); @@ -95,6 +94,8 @@ void Thread::start_searching(bool resume) { void Thread::idle_loop() { + WinProcGroup::bindThisThread(idx); + while (!exit) { std::unique_lock lk(mutex); @@ -122,7 +123,7 @@ void Thread::idle_loop() { void ThreadPool::init() { - push_back(new MainThread); + push_back(new MainThread()); read_uci_options(); } @@ -149,7 +150,7 @@ void ThreadPool::read_uci_options() { assert(requested > 0); while (size() < requested) - push_back(new Thread); + push_back(new Thread()); while (size() > requested) delete back(), pop_back(); @@ -158,15 +159,26 @@ void ThreadPool::read_uci_options() { /// ThreadPool::nodes_searched() returns the number of nodes searched -int64_t ThreadPool::nodes_searched() { +uint64_t ThreadPool::nodes_searched() const { - int64_t nodes = 0; + uint64_t nodes = 0; for (Thread* th : *this) - nodes += th->rootPos.nodes_searched(); + nodes += th->nodes.load(std::memory_order_relaxed); return nodes; } +/// ThreadPool::tb_hits() returns the number of TB hits + +uint64_t ThreadPool::tb_hits() const { + + uint64_t hits = 0; + for (Thread* th : *this) + hits += th->tbHits.load(std::memory_order_relaxed); + return hits; +} + + /// ThreadPool::start_thinking() wakes up the main thread sleeping in idle_loop() /// and starts a new search, then returns immediately. @@ -175,7 +187,7 @@ void ThreadPool::start_thinking(Position& pos, StateListPtr& states, main()->wait_for_search_finished(); - Search::Signals.stopOnPonderhit = Search::Signals.stop = false; + ponder = stopOnPonderhit = stop = false; Search::Limits = limits; Search::RootMoves rootMoves; @@ -198,7 +210,8 @@ void ThreadPool::start_thinking(Position& pos, StateListPtr& states, for (Thread* th : Threads) { - th->maxPly = 0; + th->nodes = 0; + th->tbHits = 0; th->rootDepth = DEPTH_ZERO; th->rootMoves = rootMoves; th->rootPos.set(pos.fen(), pos.is_chess960(), &setupStates->back(), th);