X-Git-Url: https://git.sesse.net/?p=stockfish;a=blobdiff_plain;f=src%2Fthread_win32.h;h=47516c62719d6de6bf2d89f0666f21ccd0bc6dd6;hp=a3abd65cbfb7863913fa0ab1b11c569d00d1d6b1;hb=77fa960f8923ca83ba0391835d50f4230ac6a345;hpb=6027652773c8fbf10ea2c38abd4445dd54bfd8e7;ds=sidebyside diff --git a/src/thread_win32.h b/src/thread_win32.h index a3abd65c..47516c62 100644 --- a/src/thread_win32.h +++ b/src/thread_win32.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 @@ -24,11 +25,11 @@ /// relies on libwinpthread. Currently libwinpthread implements mutexes directly /// on top of Windows semaphores. Semaphores, being kernel objects, require kernel /// mode transition in order to lock or unlock, which is very slow compared to -/// interlocked operations (about 30% slower on bench test). To workaround this +/// interlocked operations (about 30% slower on bench test). To work around this /// issue, we define our wrappers to the low level Win32 calls. We use critical /// sections to support Windows XP and older versions. Unfortunately, cond_wait() /// is racy between unlock() and WaitForSingleObject() but they have the same -/// speed performance of SRW locks. +/// speed performance as the SRW locks. #include #include @@ -57,29 +58,7 @@ private: CRITICAL_SECTION cs; }; -struct ConditionVariable { - ConditionVariable() { hn = CreateEvent(0, FALSE, FALSE, 0); } - ~ConditionVariable() { CloseHandle(hn); } - void notify_one() { SetEvent(hn); } - - void wait(std::unique_lock& lk) { - lk.unlock(); - WaitForSingleObject(hn, INFINITE); - lk.lock(); - } - - void wait_for(std::unique_lock& lk, const std::chrono::milliseconds& ms) { - lk.unlock(); - WaitForSingleObject(hn, ms.count()); - lk.lock(); - } - - template - void wait(std::unique_lock& lk, Predicate p) { while (!p()) this->wait(lk); } - -private: - HANDLE hn; -}; +typedef std::condition_variable_any ConditionVariable; #else // Default case: use STL classes