떨어지는 소비자 생산자

Question

모든 소스에서 데이터를 가져 오는 스레드 (생산자)가 t mSec입니다. 데이터가 수집되고 준비되면 다른 스레드 (소비자)가 데이터를 가져와 처리해야합니다.

그러나, 스레드가 빠른 보장이 (생산자가 소비자보다 느리게 또는 빠르게하지 않을 수 있습니다

내가 무슨 짓을 :. 소비자를 고려

//Producer 
while(is_enabled_) { 
    std::chrono::high_resolution_clock::time_point t1 = std::chrono::high_resolution_clock::now(); 
    std::unique_lock<std::mutex> lk(mutex_); 
    ready_ = false; 
    //acquiring the data 
    ready_ = true; 
    lk.unlock(); 
    cv_.notify_all(); 
    std::chrono::high_resolution_clock::time_point t2 = std::chrono::high_resolution_clock::now(); 
    auto duration = std::chrono::duration_cast<std::chrono::milliseconds>(t2 - t1).count(); 
    std::this_thread::sleep_for(std::chrono::milliseconds(sleep_milliseconds < duration ? 0 : sleep_milliseconds - duration)); 
} 

모두 않습니다 같은 :

//A consumer 
while(is_enabled_){ 
    std::unique_lock<std::mutex> lk(mutex_); 
    cv_.wait(lk, [this] {return this->ready_; }); 
    //Process the data 
} 

대기열이 없습니다. 마지막으로 획득 한 데이터 만 처리해야하며, 각 데이터는 한 번만 처리해야합니다. 일부 데이터가 수집되어 소비자가 시간을 찾지 못했습니다. e를 처리하려면 데이터가 삭제되고 다른 데이터가 제작자에 의해 덮어 씁니다.

반면에 소비자가 생산자보다 빠르면 소비자는 이전 데이터를 처리하는 대신 새 데이터가 준비 될 때까지 기다려야합니다.

생산자가 새로운 데이터를 생성 할만큼 충분히 빠르지 않은 경우 소비자가 생산자가 만든 동일한 이전 데이터를 사용하고 있다는 문제가 있습니다.

구현이 부족합니다.

Answer 1

당신은 당신의 목표를 달성하기 위해 이런 일을 인해 수 :

글로벌 변수 : 생산자에 대한 std::vector<bool> newData;

: while 루프 전에 소비자에

while(is_enabled_) { 
    std::chrono::high_resolution_clock::time_point t1 = std::chrono::high_resolution_clock::now(); 
    std::unique_lock<std::mutex> lk(mutex_); 
    ready_ = false; 
    //acquiring the data 
    ready_ = true; 
    std::fill(newData.begin(), newData.end(), true); 
    lk.unlock(); 
    cv_.notify_all(); 
    std::chrono::high_resolution_clock::time_point t2 = std::chrono::high_resolution_clock::now(); 
    auto duration = std::chrono::duration_cast<std::chrono::milliseconds>(t2 - t1).count(); 
    std::this_thread::sleep_for(std::chrono::milliseconds(sleep_milliseconds < duration ? 0 : sleep_milliseconds - duration)); 
} 

는 수행

int index; 
std::unique_lock<std::mutex> lk(mutex_); 
index = newData.size(); 
newData.push_back(false); 
lk.unlock(); 

그러면 몸은 이렇게됩니다.

while(is_enabled_){ 
    std::unique_lock<std::mutex> lk(mutex_); 
    if(newData[index]) { 
     cv_.wait(lk, [this] {return this->ready_; }); 
     newData[index] = false; 
    //Process the data 
    }else { 
      lk.unlock(); 
      std::this_thread::sleep_for(std::chrono::milliseconds(50); 
    } 
} 

희망이 있습니다.