C++状態変数の通知が期待どおりに動作しない

Question

worker_threadがで始まった直後に新しいスレッドを起動しようとしていますが、終了していない可能性があります。私は開始と終了の仕事を時間の遅れに置き換えました。私のコードは次のとおりです。

#include <iostream> 
#include <string> 
#include <mutex> 
#include <condition_variable> 
#include <future> 
#include <atomic> 
#include <chrono> 
#include <thread> 

std::mutex m; 
std::condition_variable cv; 
bool started = false; 

void worker_thread() 
{ 
    std::unique_lock<std::mutex> lk(m); 

    static std::atomic<int> count(1); 
    std::this_thread::sleep_for(std::chrono::milliseconds{(count % 5) * 100}); 
    std::cerr << "Start Worker thread: " << count << "\n"; 

    started = true; 
    lk.unlock(); 
    cv.notify_one(); 

    std::this_thread::sleep_for(std::chrono::milliseconds{3000}); 
    std::cerr << "Exit Worker thread: " << count << "\n"; 
    ++count; 
} 

int main() 
{ 
    while(1) { 
     std::async(std::launch::async, worker_thread); 
     std::unique_lock<std::mutex> lk(m); 
     cv.wait(lk, []{return started;}); 
     started = false; 
    } 
} 

出力は以下のようになります。

私が欲しかった行動ではない

Start Worker thread: 1 
Exit Worker thread: 1 
Start Worker thread: 2 
Exit Worker thread: 2 
Start Worker thread: 3 
Exit Worker thread: 3 
Start Worker thread: 4 
Exit Worker thread: 4 
Start Worker thread: 5 
Exit Worker thread: 5 

。作業が前のスレッドに終了すると、現在次のスレッドのみが開始され

Start Worker thread: 1 
Start Worker thread: 2 
Start Worker thread: 3 
Start Worker thread: 4 
Exit Worker thread: 1 
Exit Worker thread: 3 
Exit Worker thread: 4 
Exit Worker thread: 2 
Start Worker thread: 5 
Exit Worker thread: 5 

：私が望んでいたことは、この（ない正確に）のようなものでした。しかし、私は前のスレッドで仕事が始まり、それが終わるのを待たずにすぐに次のスレッドを開始したいと思っています。

Answer 1

std::asyncは、関数実行の結果を保持するstd::futureを返します。あなたの場合、それは一時的に破壊されたオブジェクトです。 std::futureのドキュメントは言う：

these actions will not block for the shared state to become ready, except that it may block if all of the following are true：

共有状態は、まだこの✔

準備ができていない✔共有状態ははstd ::し

非同期（async）呼び出しによって作成されました✔共有状態への最後の参照でした

これらのすべてが真であり、破壊fはfutureで、ワーカー関数の実行が終了するまでブロックされます。

あなたがこの問題を回避するために切り離されたスレッドを作成することができます。

std::thread(worker_thread).detach();