Как в программе дождаться выполнения всех потоков std::thread перед выходом из функции?

Question

[pixik]

Доброго времени!
У меня есть 2 объекта в основе которых, путем композиции, инкапсулирован std::thread.
В программе нужно запустить оба потока и ждать, пока они не завершатся. Когда я выполняю:

somethread t1, t2;
t1.start();
t2.start();
t1.join();
t2.join();
// some work
exit();

то привязывается к основному потоку только t1, а t2 сам по себе.

В книге Уильямса "Параллельное программированиие на c++", читал про thread_guard, что то вроде защиты потока, где в деструкторе выполняется join() к охраняемому потоку и ждет, пока поток не завершится. Но возможно есть какие то штатные std::* средства, которые позволяют это делать.

Comments

[Владимир Мартьянов]

Если бы то была винда и системные треды - WaitForMultipleObjects было бы в самый раз...

[pixik]

Владимир Мартьянов: ОС - linux.
Думаю, наверно действительно, если нужно дожидаться, чтобы потоки завершались, то аккуратнее будет это сделать с помощью thread_guard.

[MiiNiPaa]

Я подозреваю, что что-то не так в реализации somethread: если join() вызывает join() хранящегося std::thread, то выполнение будет заблокировано пока поток не завершится.

> Но возможно есть какие то штатные std::* средства, которые позволяют это делать.
Чтобы ждать, пока std::thread не завершил работу, нужно сделать join(). Возможно вы что-то делаете не так. Создайте минимальный рабочий пример показывающий проблему, без ненужного кода и запостите ссылку на онлайн компилятор с этим кодом.

Answer 1

[Олег Цилюрик]

то привязывается к основному потоку только t1, а t2 сам по себе.

Вообще непонятно что эта фраза могла бы означать?
Никто ни к кому не "привязывается", а pthraed_join() (над чем надстроены все ваши std::thread или boost::thread) - всего лишь ожидает завершения присоединённого (созданного в состоянии PTHREAD_CREATE_JOINABLE) потока.

У вас просто в архитектуре гипотетического приложения - ошибка, а в голове - путаница (относительно потоков).

Comments

[pixik]

| У вас просто в архитектуре гипотетического приложения - ошибка, а в голове - путаница (относительно потоков).

Спасибо, толковое объянение)
Вы можете посоветовать что почитать на тему потоков, чтобы хорошо разобраться? Я сейчас читаю книгу "параллельное программирование на с++" Уильямса. Может быть я не с того начал или еще чего.

В общим, проблема с разделенным ресурсом между потоками. Это boost::io_service. я читал про корректную обработку закрытия сокета и там говорилось примерно следующее, что нужно остановить цикл обработки очереди событий (event loop) в io_service, а потом выполнить socket_obj.close(err);
если одному потоку удается аккуратно закрыть соединение, то второй крашится от того, что io_service уже закрыл event_loop. может быть там фигня какая. Я в boost не силен(

[Олег Цилюрик]

pixik:

Вы можете посоветовать что почитать на тему потоков, чтобы хорошо разобраться?

Любые обёртки C++, Boost и др. - только вуалируют для вас то, что происходит "под крышкой", а там всегда - pthread_t, C, POSIX...
Посмотрите здесь, например ...можно по верхам:


Когда будет ясность с основой - можете с лёгкостью использовать Boost и т.п.

[pixik]

Олег Цилюрик: Ценный ответ. Благодарю.

Answer 2

[iv_k]

вариант с бустом
вам не так примерно надо?

boost::thread_group g;
g.create_thread(boost::bind(&t1));
g.create_thread(boost::bind(&t2));
// плодите потоков сколько хочется, можно в цикле
g.join_all();
// ждем пока все завершатся

Comments

[pixik]

да, примерно так) я не понимаю, как можно сделать join_all. Как это в реализации работает? ведь как только делаешь join(), то основной поток выполнения ждет, пока присоединенный завершит работу.
Единственное, что приходит на ум, это сделать обёртку над std::thread и в деструкторе этой обертки сделать thread_guard

[iv_k]

вот внутренности из буста
void join_all()
{
boost::shared_lock guard(m);

for(std::list::iterator it=threads.begin(),end=threads.end();
it!=end;
++it)
{
(*it)->join();
}
}