сигнализация родительских потоков в C++ 11

Question

У меня есть функция, которую я хочу запускать в разных потоках. Функция заполняет структуру данных, например:

per_thread(int start_value, std::vector<SomeStruct>& reference) 
{ 
    for (size_t i = 0; i < 500; i++) 
    { 
     reference.push_back(func(i)); 
     if (i == 2) 
      send_signal_back(); 
    } 
} 

Однако, после того, как это делается происходит через петлю некоторое число раз, я хочу, чтобы начать другую нить, используя это в качестве начального значения. К сожалению, я не понимаю, как отправить сигнал обратно в родительский поток.

Так что я хочу что-то вроде этого:

for(size_t j = 0; j < 5000; j += num_threads) 
{ 
    for (size_t i = 0; i < num_threads; i++) 
    { 
     std::async(per_thread(foo(j+i), std::ref(vec)); 
     //wait for signal 
    } 
} 

Как послать такой сигнал?

Answer 1

Я бы не использовал async, потому что это слишком высокоуровневый и делает что-то еще. (Вот little rant of mine, который касается async.)

Похоже, вы действительно хотите потоки и управлять ими вручную.

Попробуйте это:

#include <vector> 
#include <thread> 

std::vector<std::thread> threads; 

for (std::size_t j = 0; j < 5000; j += num_threads) 
{ 
    for (std::size_t i = 0; i != num_threads; ++i) 
    { 
     threads.emplace_back(per_thread, foo(i + j), std::ref(vec)); 
    } 
} 

for (auto & t: threads) 
{ 
    t.join(); 
} 

Это закончат когда затяжных нить закончилась. (Эффект «длинный хвост».)