単純なプロデューサーとコンシューマーのunique_lockでの難しさ

Question

C++の11個のノートに基づいて非常に単純なプロデューサー/コンシューマーを作成しましたが、なぜunique_lock（）が範囲外になったときにロックを解除しないのかわかりません。

struct Message{ 
Message(int x):data(x){cout<<"+";} 
int data; 
}; 


queue<Message*> g_queue; 
condition_variable cv; 
mutex m; 

void consumer() 
{ 
    do { 
     unique_lock<mutex> lck {m}; 
     cv.wait(lck, [&](){return !g_queue.empty();}); 
     cout<<"Notified..."; 
     auto& obj = g_queue.front(); 
     std::cout<<obj->data; 
     g_queue.pop(); 
     cout<<"."; 
     lck.unlock(); -----(1) 
    } while(1); 

} 

void producer() 
{ 
    while(true){ 
      unique_lock<mutex> lck {m}; 
      Message msg{5}; 
      cout<<"Queue size:"<<g_queue.size()<<'\n'; 
      g_queue.push(&msg); 
      cv.notify_one(); 
      lck.unlock(); -------(2) 
      cout<<"-"<<'\n'; 
      this_thread::sleep_for(std::chrono::milliseconds{2000}); 
    } 
} 

としてそれを使用する： - 出力がある

thread Q(&consumer); 
    thread P(&producer); 
    P.join(); 
    Q.join(); 

： -

+Queue size:0 
-Notified... 
5.+Queue size:0 
-Notified...5 
.+Queue size:0 
-Notified...5 

だから、技術的には、はい、プロデューサーは、私は準備ができている消費者に伝える必要があると消費者にする必要がありますProducerにより多くのデータを送信させる。私は何を使うべきかについて明確ではない、条件変数がこれを行うのか、それともunique_lockがこれをするのか。

まさに、私が必要とする理由（1）及び（2）範囲は、以下のロック

==編集== を解放することができるときで正常に動作し、編集コード、

void consumer() 
{ 
    do { 
     unique_lock<mutex> lck {m}; 
     cv.wait(lck, [&](){return !g_queue.empty();}); 
     cout<<"Notified..."; 
     auto& obj = g_queue.front(); 
     std::cout<<obj->data; 
     g_queue.pop(); 
     cout<<"."; 
    } while(1); 

} 

Message msg{5}; 
void producer() 
{ 
    while(true){ 
      unique_lock<mutex> lck {m}; 
      cout<<"Queue size:"<<g_queue.size()<<'\n'; 
      g_queue.push(&msg); 
      cv.notify_one(); 
      cout<<"-"<<'\n'; 
    } 
} 

今、睡眠が危険な場合、プロデューサーやコンシューマーに欲しいと思ったら、少し絞り込んでみましょう。

Answer 1

ここでもまだ質問はありませんが、スロットルの解決策の1つは、キューがプロデューサで成長できる最大サイズを持つことです。キューがこのサイズに達すると、プロデューサは異なる条件変数で待機します。キューが特定のサイズを下回ると、コンシューマはこの第2の条件変数を通知します。 （いくつかのヒステリシスを与えるために後者のサイズはおそらく最大値より多少小さい）この新しい条件変数の待機の述語はg_queue.size() >= max_sizeです。