スレッドスターベートを防ぐ方法

Question

私はゼロレイテンシのクラウドゲームサーバーを作成しています。それはソフトウェアのパイプラインです。最初の段階では画面をキャプチャし、2番目の段階ではビデオにエンコードします。

しかし第二段階のフリーズ、ある程度の時間後。私は多くのプラットフォームに依存しないアプローチを試みましたが、静脈ではどちらかが最終的にフリーズします。 How to prevent threads from starvation in C++11の答えは、mutexを使うべきだと述べています。私はそれを試してみました。それは長く続くことができますが、時には（まれに）時折凍ることがあります。ミューテックスはスレッドの飢餓を防ぐための明確なヒントではないと私は思う。 （多分私が間違っているの？）

今私はミューテックスを使用すると同時に、Windowsの優先順位のブースト機能を無効にするが、私は全くこのソリューションを好きではありません。誰も飢餓のない生産者と消費者（C++ 11では良い）の例を提供することができますか？

プロデューサー：

while(Streamer.IsConnected()) { 
    uint8_t *pBits = Streamer.AcquireNext(); 
    // The buffer is full 
    if(pBits && get_counter(&fps_limiter) >= 1000/args.m_MaxFps && check_target_window(args.m_TargetWindow.c_str(), limit, &rect)) { 
     BROFILER_FRAME("MainLoop") 
     start_counter(&fps_limiter); 
     if(!FAILED(capture_screen(g_DXGIManager, rect, pBits))) 
      Streamer.PushNext(); 
    } 
    else { 
     this_thread::yield(); 
     // lower cpu usage 
     Sleep(1); 
     continue; 
    } 

    if (get_counter(&bit_rate) >= 1000) { 
     uint32_t bps = Streamer.GetBitRate(); 
     printf("\rBirate: %u bps, %u Bps\t\t\t\t\t", bps, bps/8); 
     start_counter(&bit_rate); 
    } 
} 

消費者：

while(!m_ServerShouldStop) { 
     uint8_t *data = AcquireLast(); 
     if (!data) { 
      this_thread::yield(); 
      Sleep(1); 
      continue; 
     } 
     // encoder callback 
     uint8_t *out; 
     uint32_t size = m_Encoder(data, &out); 

     PopLast(); 

     // If encoder output something, send it immediately 
     if(size>0) { 
      // send the size of buffer 
      int res1 = ::send_whole_buffer(client_sck, reinterpret_cast<uint8_t *>(&size), 
       sizeof(size)); 
      // then the contents 
      int res2 = ::send_whole_buffer(client_sck, out, size); 

      bytes += size; 

      if (m_EventHandler) 
       m_EventHandler->onFrameSent(); 

      // If any of them fails.... 
      if(!res1||!res2) 
       break; 
     } 
     if (get_counter(&counter) >= 1000) { 
      m_Bps = bytes * 8; 
      bytes = 0; 
      start_counter(&counter); 
     } 

    } 
... 

は当初、私は循環キューへの保護をしませんでした。競争状態はないと思う（プロデューサーと消費者はそれぞれ1人）。それから私は

Answer 1

ワード凍結は、スレッドの不足ではなく、競合状態を意味します....ミューテックス何も変更を追加してみてください。関係するすべてのスレッドが単一のミューテックスおよび単一のスレッド（またはスレッドの数）飢餓状態に他のスレッドを残しミューテックスをつかんで保持するために競合している場合

スレッド不足です。これは、1つのミューテックスに対する競争がそれほどない場合には、悪いアプリケーション設計の例です。

しかし、あなたはフリーズしています。だから凍結とは、（2つ以上の）スレッドのどちらもミューテックスやコード内の他の制約を取得できないレース状態になったことを意味します。

いかなる価値のある答えを提供するために、あなたの質問に十分な情報がありません。正確に何をしているのか正確に何が起こっているのかのコードサンプルを提供してください。

Answer 2

私は私のローカル変数は私の同僚の機能によって破損していることがわかりました。 libx264が正しく動作しない。実際には、コードはロックフリーで書くことができます。 stiil、ミューテックスを追加することはビジーな待合よりも優れています。 CPU使用量を大幅に減らすことができます