は、私は次のようにループを作成する必要があり、順次スレッド

Question

でconfilicts避けてください：各反復において

while (!end) { 

    // some modifications to myPar 

    boost::thread t(&myClass::myFun, this, myPar); 

    // other operations 
} 

を、私はスレッドが前の反復で呼び出す1が終了したときにのみ起動します。しかし、私は "他の操作"がそれを待つことを望んでいません。 これを行う方法はありますか？

Answer 1

私はブースト::スレッドで遊んでいませんでしたが、これに似た何かが、あなたがこの

class Worker 
{ 

public: 
    void addParams(const SomeParams &params) 
    { 
     paramsQueue.push(params); 
    } 

    void start() 
    { 
     auto loop = [this]() 
     { 
      while(!interrupted) 
      { 
       //BLOCK HERE if queue is empty 

       auto params = paramsQueue.pop(); 

       //do something with params 
      } 
     }; 

     thread = {loop}; 
    } 

    void interrupt() 
    { 
     interrupted = true; 
    } 

private: 
    boost::thread thead; 
    std::queue<SomeParams> paramsQueue; 
    bool interrupted = false; 
}; 


... 

Worker worker; 

worker.start(); 

while (!end) { 

    // some modifications to myPar 

    worker.addParams(params); 

    // other operations 
} 

ような何かを行うことができます

boost::thread t; 
while (!end) { 

    // some modifications to myPar 
    if(t.joinable()) 
      t.join(); 

    t = {&myClass::myFun, this, myPar}; 

    // other operations 
} 

EDIT に関するコメントを動作しますが、実装するために覚えておく必要がありますあなたが空のキューを読み込もうとすればあなたはUBを持つでしょうから。また、キューからのプッシュとポップはスレッドセーフでなければなりません。