1

здравствуйте, вот, допустим, вызываем основной поток, делаем что-то, далее запускаем несколько других потоков, которые должны исполняться строго асинхронно(притом каждый из них разное время исполняется), приостанавливаем основной, а после завершения каждого из вызываемых потоков продолжаем выполнять основной. подходит ли следующий код для такой стратегии, или есть более красивые решения:

#include <thread>
#include <mutex>
#include <condition_variable>

int main() {
    //идет основной поток
    //...
    std::condition_variable var;
    std::mutex m;
    //пусть будут три потока с разной длительностью
    std::atomic<bool> a1(false);
    std::atomic<bool> a2(false);
    std::atomic<bool> a3(false);
    std::thread([&]{ std::this_thread::sleep_for(std::chrono::milliseconds(3000)); a1 = true; var.notify_one();}).detach();
    std::thread([&]{ std::this_thread::sleep_for(std::chrono::milliseconds(7000)); a2 = true; var.notify_one();}).detach();
    std::thread([&]{ std::this_thread::sleep_for(std::chrono::milliseconds(500)); a3 = true; var.notify_one();}).detach();

    {
        std::unique_lock<std::mutex> locker(m);
        while(!(a1 && a2 && a3))
            var.wait(locker);
    }
    //...
    // продолжаем основной поток

з.ы. в общем можно было просто все потоки джоинить и все, я чет сразу не допер. к тому же даже ожидание криво реализовано, надо было так:

{
     std::unique_lock<std::mutex> locker(m);
     var.wait(locker, [&]{ return (a1 && a2 && a3);});
}
16
  • Вроде ж для cond.var нужно отправлять нотификацию под мьютексом? Заодно и не понадобится std::atomic.
    – VladD
    31 янв 2017 в 22:53
  • не понял вас... атомики защищают от ложного пробуждения
    – xperious
    31 янв 2017 в 23:02
  • Хм, а каким образом защищают? Можно ссылку про это почитать?
    – VladD
    31 янв 2017 в 23:14
  • ну не сами атомики, а условие в цикле, как тут, например, habrahabr.ru/post/182626 другое дело, что достаточно, по идее и обычного булевского типа, однако вдруг там процессор переставит переменные и т.д., короче атомики имхо надежнее
    – xperious
    31 янв 2017 в 23:31
  • А вот должно быть не «а вдруг», а надо точно знать, какая конструкция что гарантирует. Вот блокировка мьютекса в пишущем потоке гарантирует, например, отсутствие всяческих «перестановок». И необходимость использовать медленный atomic отпадает.
    – VladD
    31 янв 2017 в 23:46

1 ответ 1

2

Достаточно использовать функцию join для ожидания выполнения потоков. Рабочий пример:

void f(int n) {
    for (int i = 0; i < 10; ++i) {
        std::cout << "Message from thread #" << n << ": iteration #" << i << "\n";
        std::this_thread::sleep_for(std::chrono::milliseconds(200));
    }
}

int main() {
    std::cout << "Main thread: build threads pool\n";
    std::vector<std::thread> pool;
    pool.push_back(std::thread{f, 1});
    pool.push_back(std::thread{f, 2});
    pool.push_back(std::thread{f, 3});
    std::for_each(pool.begin(), pool.end(), std::mem_fn(&std::thread::join));
    std::cout << "Main thread: all threads finished.\n";
}

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.