X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=src%2Fthread.cpp;h=c73f55660330545d300857b2874287fd54b21563;hb=2ca142a5b4ca200c56cb99495ec51a804983d07d;hp=a715d44ee17b2e5844e4be101b246041e9bc9c7d;hpb=26dabb1e6bcd8035f0f3516c4358a73f2b041a1c;p=stockfish diff --git a/src/thread.cpp b/src/thread.cpp index a715d44e..c73f5566 100644 --- a/src/thread.cpp +++ b/src/thread.cpp @@ -38,9 +38,9 @@ namespace { // when start_routine (and hence virtual idle_loop) is called and when joining. template T* new_thread() { - T* th = new T(); - th->nativeThread = std::thread(&ThreadBase::idle_loop, th); // Will go to sleep - return th; + std::thread* th = new T; + *th = std::thread(&T::idle_loop, (T*)th); // Will go to sleep + return (T*)th; } void delete_thread(ThreadBase* th) { @@ -50,7 +50,7 @@ namespace { th->mutex.unlock(); th->notify_one(); - th->nativeThread.join(); // Wait for thread termination + th->join(); // Wait for thread termination delete th; } @@ -61,7 +61,7 @@ namespace { void ThreadBase::notify_one() { - std::unique_lock(this->mutex); + std::unique_lock lk(mutex); sleepCondition.notify_one(); } @@ -299,9 +299,12 @@ void ThreadPool::init() { void ThreadPool::exit() { delete_thread(timer); // As first because check_time() accesses threads data + timer = nullptr; for (Thread* th : *this) delete_thread(th); + + clear(); // Get rid of stale pointers } @@ -320,7 +323,7 @@ void ThreadPool::read_uci_options() { // If zero (default) then set best minimum split depth automatically if (!minimumSplitDepth) - minimumSplitDepth = requested < 8 ? 4 * ONE_PLY : 7 * ONE_PLY; + minimumSplitDepth = 5 * ONE_PLY ; while (size() < requested) push_back(new_thread()); @@ -353,8 +356,6 @@ void ThreadPool::start_thinking(const Position& pos, const LimitsType& limits, StateStackPtr& states) { main()->join(); - SearchTime = now(); // As early as possible - Signals.stopOnPonderhit = Signals.firstRootMove = false; Signals.stop = Signals.failedLowAtRoot = false;