アクティブなスレッドでwhileループを中断する方法

Question

私はそれが私の質問を語る最良の方法ではないことを知っています。私のサーバーでは、いくつかの問題が基本的にこれにまで及んでいます - conditionAが満たされたらwhileループからどのように壊れますか？ conditionBが満たされていれば、特定のスレッドを破棄することは可能ですか？

残念ながら、ループから壊れることができない限り、メインスレッドはrecvfrom（）関数によって永遠にブロックされます。

while (1) 
{ 
    recBytes = recvfrom(sock, packetBuff, 8, 0, (struct sockaddr *) &client, &SockLength); 

    std::thread TX([&] 
    { 
    //process packet task 

    if(conditionA == 1) 
     break from while loop 

    if(conditionB == 1) 
     destroy any active threads spawned by TX 

    . 
    . 
    . 
    much more tasks 

    }); 

    TX.detach(); 
} 

. 
. 
. 
continue rest of code 

ありがとうございます！

Answer 1

ブロッキングI/Oコールを中断する標準的な方法は、データソケットとノンブロッキング通知パイプの2つのソケットを待機するselect（）/ poll（）/ etcに置き換えます。 select（）があなたのデータソケットを読み書きすることができると報告するならば、非ブロック的な方法でそれを行うだけです。通知パイプでデータが利用可能であると報告された場合は、ループを解除します。どのスレッドも、非ブロッキング通知パイプに1バイトを書き込んで、別のスレッドのselect（）を返すことができます。

他のスレッドを破壊するには、それらのスレッドからの協力なしには実行できません。基本的に、終了する必要があることを通知する方法が必要です。それらのスレッドが呼び出しをブロックしない場合、定期的なチェックを伴う簡単なアトミックフラグが行います。それ以外の場合は、ブロッキングコールから切断する方法が必要です。それがI/Oコールの場合は、別の通知パイプを導入してください。条件変数でブロックしている場合は、std :: condition_variable :: notify_all（）を使用します。