QtConcurrent::mappedReduced 没有映射

问题描述

考虑以下代码(Qt 6.0.3,C++17):

const QVector<int> arr = {1,2,3,4,5};
auto future = QtConcurrent::mappedReduced<int>(arr,[](auto item) {
    return item;
},[](int& result,auto item) {
    result += item;
});

如您所见,传递给 QtConcurrent::mappedReduced 的第一个 lambda 表达式看起来没有必要。这就是为什么我想在 Qt 6 中找到类似 QtConcurrent::reduced 的东西。或者我如何重构这段代码以仅使用 1 个 lambda 表达式?

解决方法

您可以使用 std::accumulate

QtConcurrent mappingReduce 的目标是以并发方式对容器的所有项目应用操作,一旦完成就进行归约。

在您的情况下,除了项目的总和外,无需执行任何操作,因此不需要mappedReduce。

更新

根据您的评论,这里是一个使用自定义类的示例,其中 operator+ 使用 QList 作为容器重载。

class MyClass
{
public:
    MyClass(int x=0,int y=0):
       _x(x),_y(y)
    {}

    int x() const { return _x; }
    int y() const { return _y; }

public:
    int _x;
    int _y;
};

MyClass operator+(const MyClass& left,const MyClass &right)
{
    MyClass m;
    m._x = left._x + right._x;
    m._y = left._y + right._y;
    return m;
}

这是一个带有 std::accumulate

的版本
#include <QVector>
#include <QtDebug>
#include <numeric>

int main(int argc,char **argv)
{
    Q_UNUSED(argc);
    Q_UNUSED(argv);

    QVector<MyClass> myClassList = {MyClass(12,42),MyClass(23,53)};
    MyClass result = std::accumulate(myClassList.constBegin(),myClassList.constEnd(),MyClass());
    qDebug() << result.x() << result.y();
    return 0;
}

更新 2:

根据@IlBeldus 的建议,这是您将 std::accumulateQtConcurrent::run 一起使用的版本

#include <QtDebug>
#include <QVector>
#include <QtConcurrent>
#include <numeric>

MyClass myAccumulate(const QVector<MyClass> &input)
{
    return std::accumulate(input.constBegin(),input.constEnd(),MyClass());
}

int main(int argc,53)};
    QFuture<MyClass> future = QtConcurrent::run(myAccumulate,myClassList);
    result = future.result();
    qDebug() << result.x() << result.y();
    return 0;
}