Qt学习笔记之Concurrent Map和Map

QtConcurrent::map()、QtConcurrent::mapped()和QtConcurrent::mappedReduced()函数在一个序列中（例如：QList或QVector）的元素上并行地运行计算。QtConcurrent::map()直接修改一个序列，QtConcurrent::mapped()返回一个包含修改内容的新序列，QtConcurrent::mappedReduced()返回一个单独的结果。

这些函数是Qt之Concurrent框架的一部分。

上述每个函数都有一个blocking变量，其返回最终结果而不是一个QFuture。以和异步变量同样的方式来使用它们。

QList<QImage> images = ...; // 每一个都调用blocks，直到整个操作完成 QList<QImage> future = QtConcurrent::blockingMapped(images, scaled); QtConcurrent::blockingMap(images, scale); QImage collage = QtConcurrent::blockingMappedReduced(images, scaled, addToCollage);

注意：上述的结果类型不是QFuture对象，而是实际结果类型（在这种情况下，QList<QImage>和QImage）。

简述

Concurrent Map

Concurrent Map-Reduce

附加API功能

使用迭代器而不是序列

Blocking变量

使用成员函数

使用函数对象

使用绑定函数参数

更多参考

Concurrent Map

QtConcurrent::mapped()接受一个输入序列和map函数，该map函数被序列中的每个元素调用，返回一个包含map函数返回值的新序列。

map函数必须是下面的形式：

U function(const T &t);

T和U可以是任意类型（它们甚至可以是同一类型），但是T必须匹配存储在序列中的类型，函数返回修改或映射的内容。

下面示例介绍了如何为序列中的所有元素都应用scale函数：

QImage scaled(const QImage &image) { return image.scaled(100, 100); } QList<QImage> images = ...; QFuture<QImage> thumbnails = QtConcurrent::mapped(images, scaled);

map的结果通过QFuture可用。查看QFuture和QFutureWatcher的文档，了解更多关于程序中如何使用QFutured的内容。

如果想直接修改一个序列，使用QtConcurrent::map()。map函数必须是以下形式：

U function(T &t);

注意： map函数的返回值、返回类型没有被使用。

使用QtConcurrent::map()和使用QtConcurrent::mapped()类似：

void scale(QImage &image) { image = image.scaled(100, 100); } QList<QImage> images = ...; QFuture<void> future = QtConcurrent::map(images, scale);

由于该序列被直接修改，QtConcurrent::map()不通过QFuture返回任何结果。然而，你仍然可以使用QFuture和QFutureWatcher监控map的状态。

Concurrent Map-Reduce

QtConcurrent::mappedReduced()类似于QtConcurrent::mapped()，但是返回一个新结果序列，通过一个reduce函数，结果被组合成一个值。

reduce函数必须是以下形式：

V function(T &result, const U &intermediate)

T是最终结果的类型，U是map函数的返回类型。注意： reduce函数的返回值、返回类型并没有被使用。

调用QtConcurrent::mappedReduced()如下所示：

void addToCollage(QImage &collage, const QImage &thumbnail) { QPainter p(&collage); static QPoint offset = QPoint(0, 0); p.drawImage(offset, thumbnail); offset += ...; } QList<QImage> images = ...; QFuture<QImage> collage = QtConcurrent::mappedReduced(images, scaled, addToCollage);

reduce函数将由map函数返回的每个结果调用一次，并且应该合并中间体到结果变量。QtConcurrent::mappedReduced()可以保证保证一次只有一个线程调用reduce，所以没有必要用一个mutex锁定结果变量。QtConcurrent::ReduceOptions枚举提供了一种方法来控制reduction完成的顺序。如果使用了QtConcurrent::UnorderedReduce（默认），顺序是不确定的；而QtConcurrent::OrderedReduce确保reduction按照原始序列的顺序完成。

附加API功能 使用迭代器而不是序列

上述每个函数都有一个变量，需要一个迭代器范围，而不是一个序列。以和序列变量同样的方式来使用它们。

QList<QImage> images = ...; QFuture<QImage> thumbnails = QtConcurrent::mapped(images.constBegin(), images.constEnd(), scaled); // map直接仅运行在non-const迭代器上 QFuture<void> future = QtConcurrent::map(images.begin(), images.end(), scale); QFuture<QImage> collage = QtConcurrent::mappedReduced(images.constBegin(), images.constEnd(), scaled, addToCollage); Blocking变量

上述每个函数能有一个blocking变量，其返回最终结果而不是一个QFuture。以和异步变量同样的方式来使用它们。

QList<QImage> images = ...; // 每一个都调用blocks，直到整个操作完成 QList<QImage> future = QtConcurrent::blockingMapped(images, scaled); QtConcurrent::blockingMap(images, scale); QImage collage = QtConcurrent::blockingMappedReduced(images, scaled, addToCollage);

注意：上述的结果类型不是QFuture对象，而是实际结果类型（在这种情况下，QList<QImage>和QImage）。

使用成员函数