スレッド完了時にスレッドからベクトルを削除する

Question

vectorがthreadのC++プログラムです。

std::vector<std::thread> threadList; 

次に、スレッドを作成してvectorにプッシュします。私はthreadListvectorときlambda function終了の実行からthreadを削除するにはどうすればよい

threadList.push_back(std::thread([]() { ... })); 

？

---

編集

私は多少の溶液を作ってみました。スレッドlambda functionが返される前に、vectorを繰り返してIDの一致をthis_thread::get_id()にします。

Visual Studioで1行ずつデバッグすると、一致するものが見つかってerase関数が実行されますが、threadList.erase(threadList.begin() + index);が実行されるとすぐにスレッドのdeconstructor関数で処理されない例外が発生します。

私はこのエラーを複製する小さなコードを書いています。

vector<thread> threadList; 

threadList.push_back(thread([]() { 
    Sleep(1000); 
    threadList.erase(threadList.begin()); 
})); 

Sleep(2000); 

//for_each(threadList.begin(), threadList.end(), mem_fn(&thread::detach)); 
//threadList.clear(); 

このコードの結果、次のスクリーンショットが表示されます。

Answer 1

1つのオプションは、終了時にラムダが非同期スレッドを削除することです。また

std::vector<std::thread> threadList; 
std::mutex threadMutex; 

... 

void removeThread(std::thread::id id) 
{ 
    std::lock_guard<std::mutex> lock(threadMutex); 
    auto iter = std::find_if(threadList.begin(), threadList.end(), [=](std::thread &t) { return (t.get_id() == id); }); 
    if (iter != threadList.end()) 
    { 
     iter->detach(); 
     threadList.erase(iter); 
    } 
} 

... 

{ 
    std::lock_guard<std::mutex> lock(threadMutex); 
    threadList.push_back(
     std::thread([]() { 
      ... 
      std::async(removeThread, std::this_thread::get_id()); 
     }) 
    ); 
} 

：また

std::vector<std::thread> threadList; 
std::mutex threadMutex; 

... 

void removeThread(std::thread::id id) 
{ 
    std::lock_guard<std::mutex> lock(threadMutex); 
    auto iter = std::find_if(threadList.begin(), threadList.end(), [=](std::thread &t) { return (t.get_id() == id); }); 
    if (iter != threadList.end()) 
    { 
     iter->join(); 
     threadList.erase(iter); 
    } 
} 

... 

{ 
    std::lock_guard<std::mutex> lock(threadMutex); 
    threadList.push_back(
     std::thread([]() { 
      ... 
      std::thread(removeThread, std::this_thread::get_id()).detach(); 
     }) 
    ); 
} 

：たとえば、あなたがそれらを切り離すことができるとき

std::vector<std::thread> threadList; 
std::mutex threadMutex; 

std::list<std::thread::id> threadFreeList; 
std::mutex threadFreeMutex; 
std::condition_variable threadFreeCV; 

std::thread monitor([]() { 
    while (... /* app is not terminated */) 
    { 
     std::unique_lock<std::mutex> lock(threadFreeMutex); 
     threadFreeCV.wait(lock); 

     std::lock_guard<std::mutex> lock2(threadMutex); 
     auto iter = threadFreeList.begin(); 
     while (iter != threadFreeList.end()) 
     { 
      auto id = *iter; 
      auto found = std::find_if(threadList.begin(), threadList.end(), [=](std::thread &t) { return (t.get_id() == id); }); 
      if (found != threadList.end()) 
      { 
       found->join(); 
       threadList.erase(found); 
      } 
      iter = threadFreeList.erase(iter); 
     } 
    } 
}); 

... 

{ 
    std::lock_guard<std::mutex> lock(threadMutex); 
    threadList.push_back(
     std::thread([]() { 
      ... 
      std::unique_lock<std::mutex> lock(threadFreeMutex); 
      threadFreeList.push_back(std::this_thread::get_id()); 
      threadFreeCV.notify_one(); 
     }) 
    ); 
} 

Answer 2

なぜあなたはこのスレッドのベクトルが必要なのですか？

// Scope that outlives the threads 
boost::barrier out_barrier(N_threads+1); 

... 

// Starting the threads 
for(int i = 0; i < N_threads; i++) { 
    std::thread th([&out_barrier]() { 
     ...do the job... 
     out_barrier.wait(); 
    }); 
    th.detach(); 
} 

... 

// Wait for threads to finish 
out_barrier.wait(); 

スレッドは結合できないので、デストラクタを呼び出すことは安全です。 この場合、同期は避けられません。私の例では、すべてのスレッドを結合するために使用されています。スレッドのベクトルがある場合は、ベクトルへのアクセスを同期させる必要があります。