他のスレッドでスレッド内に割り当てられていないものがあります

Question

std::condition_variableとbool conditionを介してワーカースレッドの実行をトリガーしようとしています。作業者は通知を待ち、conditionが真であれば作業を開始します。作業後はconditionがfalseに設定されます。さらに、同期するためのミューテックスがあります。

メインスレッドでは、ループがconditionがfalseであるかどうかをチェックし、そうである場合はconditionがtrueに設定され、condition_variableに通知されます。

出力が「スパム」は作業とを目が覚めただろうと、私は期待するこのコードを実行し、何とかthread_function()でconditionへの割り当てがメインに表示されていないので、それは、一度だけ実行されますスレッド/はワーカースレッド内で失われます。代入の後、デバッガでそれを調べると、代入の後ではfalseになりますが、メインスレッドのifが評価されると、それは再び真です。

何か不足していますか？

私はこれをVS2013とVS2012で試しましたが、boolをstd::atomic_boolに置き換えようとしましたが、それでも役に立たなかったです。

#include <thread> 
#include <mutex> 
#include <condition_variable> 
#include <iostream> 
#include <atomic> 

bool condition; 
std::mutex condition_mutex; 
std::condition_variable cv; 

void thread_function() { 
    while (true) { 
     std::unique_lock<std::mutex> lock(condition_mutex); 
     cv.wait(lock); 
     std::cout << "woke up\n"; 
     if (condition) { 
      // do stuff 
      std::cout << "thread working\n"; 
      condition = false; 
      std::cout << "thread: " << (condition ? "true" : "false") << "\n"; 
     } 
    } 
} 

int main() { 
    condition = false; 
    std::thread t(&thread_function); 

    while (true) { 
     std::unique_lock<std::mutex> lock(condition_mutex); 
//  std::cout << "main: " << (condition ? "true" : "false") << "\n"; 
     if (!condition) { 
      condition = true; 
      cv.notify_one(); 
     } 
    }  
    return 0; 
} 

Answer 1

あなたは、whileループの外にロックを配置する必要があります。

void thread_function() { 
    std::unique_lock<std::mutex> lock(condition_mutex); 
    while (true) { 
     cv.wait(lock); 
     std::cout << "woke up\n"; 
     if (condition) { 
      // do stuff 
      std::cout << "thread working\n"; 
      condition = false; 
      std::cout << "thread: " << (condition ? "true" : "false") << "\n"; 
     } 
    } 
} 

スレッド関数ループを再入力するときに、非常にすぐにロックを失います。これにより、メインスレッドは誰も待機していない間にcv.notify_one()を呼び出すことができます。

Answer 2

待つ標準的な方法は、あなたの問題を解決するだろう条件を、テストが含ま：

while (!condition) cv.wait(lock); 

はhttp://en.cppreference.com/w/cpp/thread/condition_variable/waitを参照してください。