Параллельное программирование на С++ в действии. Практика разработки многопоточных программ | страница 33
Поддержка перемещения в классе >std::thread
позволяет также хранить объекты этого класса в контейнере при условии, что класс контейнера поддерживает перемещение (как, например, модифицированный класс >std::vector<>
). Это означает, что можно написать код, показанный в листинге 2.7, который запускает несколько потоков, а потом ждет их завершения.
Листинг 2.7. Запуск нескольких потоков и ожидание их завершения
>void do_work(unsigned id);
>void f() {
> std::vector
> for (unsigned i = 0; i < 20; ++i) { │
Запуск
> threads.push_back(std::thread(do_work(i))); ←┘
потоков
> } │
Поочередный
> std::for_each(threads.begin(), threads.end(),│
вызов join()
> std::mem_fn(&std::thread::join)); ←┘
для каждого потока
>}
Если потоки применяются для разбиения алгоритма на части, то зачастую такой подход именно то, что требуется: перед возвратом управления вызывающей программе все потоки должны завершиться. Разумеется, столь простая структура, как в листинге 2.7, предполагает, что каждый поток выполняет независимую работу, а единственным результатом является побочный эффект, заключающийся в изменении разделяемых данных. Если бы функция >f()
должна была вернуть вызывающей программе значение, зависящее от результатов операций, выполненных в потоках, то при такой организации получить это значение можно было бы только путем анализа разделяемых данных по завершении всех потоков. В главе 4 обсуждаются альтернативные схемы передачи результатов работы из одного потока в другой.
Хранение объектов >std::thread
в векторе >std::vector
— шаг к автоматизации управления потоками: вместо тот чтобы создавать отдельные переменные для потоков и выполнять соединение напрямую, мы можем рассматривать группу потоков. Можно пойти еще дальше и создавать не фиксированное число потоков, как в листинге 2.7, а определять нужное количество динамически, во время выполнения.
2.4. Задание количества потоков во время выполнения
В стандартной библиотеке С++ есть функция >std::thread::hardware_concurrency()
, которая поможет нам решить эту задачу. Она возвращает число потоков, которые могут работать по-настоящему параллельно. В многоядерной системе это может быть, например, количество процессорных ядер. Возвращаемое значение всего лишь оценка; более того, функция может возвращать 0, если получить требуемую информацию невозможно. Однако эту оценку можно с пользой применить для разбиения задачи на несколько потоков.