C++ wait_until 이상한 타임 아웃 동작

Question

C++에서 일종의 스레드 풀을 작성하려고합니다. 이 코드는 OSX에서는 잘 작동하지만 Linux에서는 이상한 동작이 발생합니다. 약간의 디버깅 후 문제가 std :: condition_variable :: wait_until 호출로 인해 잘못된 방법으로 수행되고 있음을 발견했습니다.

#include <mutex> 
#include <chrono> 
#include <iostream> 
#include <memory> 
#include <condition_variable> 
#include <thread> 

using namespace std; 

typedef std::chrono::steady_clock       my_clock; 
typedef std::chrono::duration<float, std::ratio<1> >  seconds_duration; 
typedef std::chrono::time_point<my_clock, seconds_duration> timepoint; 

timepoint my_begin = my_clock::now(); 

float timepointToFloat(timepoint time) { 
    return time.time_since_epoch().count() - my_begin.time_since_epoch().count(); 
} 

void printNow(std::string mess) { 
    timepoint now = my_clock::now(); 
    cout << timepointToFloat(now) << " " << mess << endl;; 
}; 

void printNow(std::string mess, timepoint time) { 
    timepoint now = my_clock::now(); 
    cout << timepointToFloat(now) << " " << mess << " " << timepointToFloat(time) << endl;; 
}; 

int main() { 
    mutex _global_mutex; 
    condition_variable _awake_global_execution; 
    auto check_predicate = [](){ 
    cout << "predicate called" << endl; 
    return false; 
    }; 

    while (true) { 
    { // Expected to loop every three seconds 
     unique_lock<mutex> lock(_global_mutex); 
     timepoint planned_awake = my_clock::now() + seconds_duration(3); 
     printNow("wait until", planned_awake); 
     _awake_global_execution.wait_until(lock, planned_awake, check_predicate); 
    } 
    printNow("finish wait, looping"); 
    } 

    return 0; 
} 

그러나, 가끔 출력으로 얻을 : 코드와

내가 루프가 한 번에 3 초마다 루프를 기대 이하

<X> wait until <X+3> 
predicate called 
(...hangs here for a long time) 

(X는 숫자 임) 그래서 3 초 후에 타임 아웃이 예정되어 있지 않은 것 같습니다. 경우에 따라 대신 다음과 같이 표시됩니다.

<X> wait until <X+3> 
predicate called 
predicate called 
<X> finish wait, looping 
<X> wait until <X+3> (another loop) 
predicate called 
predicate called 
<X> finish wait, looping 
(...continue looping without waiting) 

그래서 시간 초과가 약간의 초 단위로 예정되어 있습니다. 나는 timeout timepoint를 가지고 뭔가를 엉망으로 만들고 있다고 생각하지만, 내가 뭘 잘못하고 있는지 알 수 없다.

관련성이있는 경우이 코드는 OSX에서 정상적으로 작동하지만 Linux (Ubuntu 16.04, gcc 5.4, "g ++ main.cc -std = C++ 11 -pthread"로 컴파일 됨)에서는 이상한 행동.

어떻게 작동시킬 수 있습니까?

Answer 1

는 시계의 시간에 타임 아웃을 던져보십시오 : 당신은 기다려야하기 전에

auto planned_awake = my_clock::now() + 
        std::chrono::duration_cast<my_clock::duration>(secon‌​ds_duration(3));