Qt Concurrent
Модуль Qt Concurrent предоставляет высокоуровневые API, которые позволяют писать многопоточные программы без использования низкоуровневых потоковых примитивов, таких как мьютексы, блокировки чтения-записи, условия ожидания или семафоры. Программы, написанные с помощью Qt Concurrent, автоматически регулируют количество используемых потоков в соответствии с количеством доступных ядер процессора. Это означает, что приложения, написанные сегодня, будут продолжать масштабироваться при развертывании на многоядерных системах в будущем.
Qt Concurrent включает API в стиле функционального программирования для параллельной обработки списков, включая реализацию MapReduce и FilterReduce для систем с общей памятью (не распределённых), и классы для управления асинхронными вычислениями в приложениях с графическим интерфейсом:
-
Параллельное отображение и Map-Reduce
- QtConcurrent::map() применяет функцию к каждому элементу в контейнере, изменяя элементы на месте.
- QtConcurrent::mapped() похож на map(), за исключением того, что он возвращает новый контейнер с изменениями.
- QtConcurrent::mappedReduced() похож на mapped(), за исключением того, что изменённые результаты сводятся или складываются в одно итоговое значение.
-
Параллельный фильтр и Filter-Reduce
- QtConcurrent::filter() удаляет все элементы из контейнера на основе результата функции фильтрации.
- QtConcurrent::filtered() похож на filter(), за исключением того, что он возвращает новый контейнер с отфильтрованными результатами.
- QtConcurrent::filteredReduced() похож на filtered(), за исключением того, что отфильтрованные результаты сводятся или складываются в одно итоговое значение.
-
Параллельный запуск
- QtConcurrent::run() выполняет функцию в другом потоке.
-
Задача QtConcurrent
- QtConcurrent::task() создаёт экземпляр QtConcurrent::QTaskBuilder. Этот объект может использоваться для настройки параметров и запуска задачи в отдельном потоке.
- QFuture представляет результат асинхронного вычисления.
- QFutureIterator позволяет итерироваться по результатам, доступным через QFuture.
- QFutureWatcher позволяет контролировать QFuture с помощью сигналов и слотов.
- QFutureSynchronizer — вспомогательный класс, который автоматически синхронизирует несколько QFutures.
- QPromise предоставляет способ сообщать о прогрессе и результатах асинхронного вычисления в QFuture. Позволяет приостановить или отменить задачу по запросу QFuture.
Qt Concurrent поддерживает несколько типов контейнеров и итераторов, совместимых со STL, но лучше всего работает с контейнерами Qt, которые имеют итераторы с произвольным доступом, такие как QList. Функции map и filter принимают как контейнеры, так и начальные/конечные итераторы.
Обзор поддержки итераторов STL:
| Тип итератора | Примеры классов | Статус поддержки |
|---|---|---|
| Вводной итератор | Не поддерживается | |
| Выходной итератор | Не поддерживается | |
| Прямой итератор | std::slist | Поддерживается |
| Двунаправленный итератор | std::list | Поддерживается |
| Итератор с произвольным доступом | QList, std::vector | Поддерживается и рекомендуется |
Итераторы с произвольным доступом могут быть быстрее в случаях, когда Qt Concurrent итерируется по большому количеству лёгких элементов, поскольку они позволяют переходить к любой точке в контейнере. Кроме того, использование итераторов с произвольным доступом позволяет Qt Concurrent предоставлять информацию о прогрессе через QFuture::progressValue() и QFutureWatcher::progressValueChanged().
Не изменяющие на месте функции, такие как mapped() и filtered(), создают копию контейнера при вызове. Если вы используете контейнеры STL, эта операция копирования может занять некоторое время, в этом случае мы рекомендуем указать начальный и конечный итераторы для контейнера вместо этого.
Использование модуля
Использование модуля Qt требует линковки с библиотекой модуля, либо напрямую, либо через другие зависимости. Несколько инструментов сборки поддерживают это, включая CMake и qmake.
Сборка с помощью CMake
Используйте команду find_package() для поиска необходимых компонентов модуля в пакете Qt6.
find_package(Qt6 COMPONENTS Concurrent REQUIRED) target_link_libraries(mytarget PRIVATE Qt6::Concurrent)
См. также обзор Сборка с помощью CMake.
Сборка с помощью qmake
Чтобы настроить модуль для сборки с помощью qmake, добавьте модуль как значение переменной QT в файле проекта .pro:
QT += concurrent
Эволюция модуля
Изменения в Qt Concurrent перечисляет важные изменения в API и функциональности модуля, которые были внесены для серии Qt 6.
Лицензии
Модуль Qt Concurrent доступен по коммерческим лицензиям от The Qt Company. Кроме того, он доступен по лицензиям свободного программного обеспечения: GNU Lesser General Public License, версия 3 или GNU General Public License, версия 2. См. Лицензирование Qt для получения дополнительной информации.
© The Qt Company Ltd
Licensed under the GNU Free Documentation License, Version 1.3.
https://doc.qt.io/qt-6.2/qtconcurrent-index.html