mappedReduced avec des fonctions objets

**Le Mérovingien** · 16/02/2010, 15h01

Bonjour,

J'aimerais utiliser le frameworks QtConcurrent, et plus précisément la fonction mappedReduced, avec des "fonctions objets". J'ai trouvé la documentation à ce sujet, il est marqué que l'on peut les utiliser, mais je n'ai pas trouver d'exemple, et tous mes tests ne fonctionnent pas. Voici le code (exemple) que j'utilise :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
#include <QApplication>
#include <QtConcurrentMap>
#include <QList>
 
//struct Puissance;
struct Puissance {
    Puissance(const int& p) : m_p(p) {}
    typedef double result_type;
    double operator() (const double & n) { int i = m_p; double r = 1.; while(i-->0) r*=n; return r; }
    int m_p;
};
 
//struct Somme;
struct Somme
{
    Somme() {}
    typedef void result_type;
    void operator() (double & result, const double & n) { result += n; }
};
 
void somme(double & result, const double & n) { result += n; }
 
int main(int argc, char** argv)
{
  QApplication app(argc, argv);
 
  QList<double> l;
  l << 1 << 2 << 3 << 4;
  qDebug() << l;
 
  Puissance p(8);
  Somme s;
  //  QFuture<double> res = QtConcurrent::mappedReduced(l, p, s);  // ne fonctionne pas
  QFuture<double> res = QtConcurrent::mappedReduced(l, p, somme);
  qDebug() << res.result();
 
  return app.exec();
}

Le but du programme est de faire la somme des éléments de la liste en les élevant au préalable à une certaine puissance. Le code posté fonctionne en utilisant la fonction somme, et ne fonctionne pas si on la remplace par l'object Somme, comme indiqué dans la ligne commentée. Je ne comprends pas pourquoi cela ne fonctionne pas, d'autant que l'object fonction Puissance est lui accepté.

L'erreur de compilation est :

main.cpp:33: error: no matching function for call to ‘mappedReduced(QList<double>&, Puissance&, Somme&)’

Bien sur dans le code final, j'ai besoin d'un objet pour y stocker un état, une fonction comme "somme" ne suffit pas.

Est ce que quelqu'un à une solution à ce problème ?

Merci d'avance

**johnlamericain** · 16/02/2010, 15h33

Humm pas évident et je ne connais pas beaucoup ce module.

N'y aurait-il pas une différence entre une MapFunction et une ReduceFunction qui fait que ça ne marche pas ?

**yan** · 16/02/2010, 16h04

le compilateur n'arrive pas a déterminer le paramètre template ResultType.
Il te suffit de le définir toi même.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

 QFuture<double> res = QtConcurrent::mappedReduced<double>(l, p, s,QtConcurrent::SequentialReduce);

Par contre, j'ai regardé un peu ce qui se passe, et les foncteur sont recopier pas mal de fois.... A en tenir compte a mon avis (je pense que suivant le foncteur, le compilo vire ces copie si elles sont inutilent)
voici le code qui t'affiche toutes les recopies de Somme et Puissance.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
#include <QApplication>
#include <QtConcurrentMap>
#include <QList>
 
//struct Puissance;
struct Puissance {
    Puissance(const int& p) : m_p(p) {}
 
    Puissance() {qDebug()<<"Puissance";}
    Puissance(const Puissance & p) {m_p =p.m_p; qDebug()<<" Puissance(const &)";}
    Puissance &operator=(const Puissance & p){m_p =p.m_p;qDebug()<<"Puissance operator="; return *this;}
 
    typedef double result_type;
    double operator() (const double & n) { int i = m_p; double r = 1.; while(i-->0) r*=n; return r; }
    int m_p;
};
 
//struct Somme;
struct Somme
{
    Somme() {qDebug()<<"Somme";}
    Somme(const Somme & ) {qDebug()<<" Somme(const &)";}
    Somme &operator=(const Somme & ){qDebug()<<"Somme operator="; return *this;}
 
    void operator() (double & res, double  n) {res += n ; }
};
 
void somme(double & result, double  n) { result += n; }
 
int main(int argc, char** argv)
{
  QApplication app(argc, argv);
 
  QList<double> l;
  l << 1 << 2 << 3 << 4;
  qDebug() << l;
 
  Puissance p(8);
  Somme s;
  QFuture<double> res = QtConcurrent::mappedReduced<double>(l, p, s,QtConcurrent::SequentialReduce);  
  //QFuture<double> res = QtConcurrent::mappedReduced(l, p, somme);
  res.waitForFinished();
  qDebug() << res.result();
 
  return 0;
}

**Le Mérovingien** · 16/02/2010, 16h55

c'est super, merci beaucoup !

C'est vrai qu'il fait beaucoup de copie, je vais essayer de voir si leur nombre est proportionnel à la taille de la séquence en entrée (j'ai bien peur que oui).

J'ai juste 2 questions : comment retirer les warning quand on compile en release (avec -O2) ? à moins qu'il n'y ait que moi qui les ai

Et sinon, si par exemple à la place de vouloir faire une somme, je voulais faire un produit, est ce qu'il y a un moyen pour passer un objet déjà initialisé comme accumulateur ? Pour le produit il faudrait 1, et non 0 comme pour la somme.

Merci beaucoup en tout cas, et chapeau pour la réactivité, comme d'habitude

**yan** · 16/02/2010, 17h03

Envoyé par Le Mérovingien

J'ai juste 2 questions : comment retirer les warning quand on compile en release (avec -O2) ? à moins qu'il n'y ait que moi qui les ai

En les traitants.
Quel warning?

Et sinon, si par exemple à la place de vouloir faire une somme, je voulais faire un produit, est ce qu'il y a un moyen pour passer un objet déjà initialisé comme accumulateur ? Pour le produit il faudrait 1, et non 0 comme pour la somme.

je sais pas. Je pense que c'est au foncteur reduce de gérer cela.
A voir

**Le Mérovingien** · 16/02/2010, 18h33

Déjà une bonne nouvelle, le nombre de copies de Puissance et Somme est constant et égal à 5 on dirait, il n'augmente pas avec le nombre d'éléments dans la séquence.

Pour les warning à la compilation, voila le log :

g++ -c -pipe -O2 -Wall -W -D_REENTRANT -DQT_NO_DEBUG -DQT_GUI_LIB -DQT_CORE_LIB -DQT_SHARED -I/usr/share/qt4/mkspecs/linux-g++ -I. -I/usr/include/qt4/QtCore -I/usr/include/qt4/QtGui -I/usr/include/qt4 -I. -I. -o main.o main.cpp
In file included from /usr/include/qt4/QtCore/qfuture.h:49,
from /usr/include/qt4/QtCore/qtconcurrentthreadengine.h:50,
from /usr/include/qt4/QtCore/qtconcurrentiteratekernel.h:51,
from /usr/include/qt4/QtCore/qtconcurrentmapkernel.h:49,
from /usr/include/qt4/QtCore/qtconcurrentmap.h:49,
from /usr/include/qt4/QtCore/QtConcurrentMap:1,
from main.cpp:2:
/usr/include/qt4/QtCore/qmap.h: In destructor ‘QFutureInterface<T>::~QFutureInterface() [with T = double]’:
/usr/include/qt4/QtCore/qmap.h:588: warning: dereferencing pointer ‘y’ does break strict-aliasing rules
/usr/include/qt4/QtCore/qmap.h:586: note: initialized from here
/usr/include/qt4/QtCore/qmap.h:588: warning: dereferencing pointer ‘y’ does break strict-aliasing rules
/usr/include/qt4/QtCore/qmap.h:586: note: initialized from here
/usr/include/qt4/QtCore/qmap.h: In destructor ‘QFutureInterface<T>::~QFutureInterface() [with T = double]’:
/usr/include/qt4/QtCore/qmap.h:588: warning: dereferencing pointer ‘y’ does break strict-aliasing rules
/usr/include/qt4/QtCore/qmap.h:586: note: initialized from here
/usr/include/qt4/QtCore/qmap.h:588: warning: dereferencing pointer ‘y’ does break strict-aliasing rules
/usr/include/qt4/QtCore/qmap.h:586: note: initialized from here
/usr/include/qt4/QtCore/qmap.h: In function ‘int main(int, char**)’:
/usr/include/qt4/QtCore/qmap.h:588: warning: dereferencing pointer ‘y’ does break strict-aliasing rules
/usr/include/qt4/QtCore/qmap.h:586: note: initialized from here
/usr/include/qt4/QtCore/qmap.h:588: warning: dereferencing pointer ‘y’ does break strict-aliasing rules
/usr/include/qt4/QtCore/qmap.h:586: note: initialized from here
g++ -Wl,-O1 -o qtconcurrent main.o -L/usr/lib -lQtGui -lQtCore -lpthread

Je ne sais pas ce que ça veut dire "dereferencing pointer ‘y’ does break strict-aliasing rules", mais je me doute que c'est une erreur dans le compilateur. Je suis sous linux et j'utilise GCC 4.4.1 fourni par ubuntu karmic, avec Qt 4.5.2. Je précise que ces warning apparaissent seulement quand je mets release dans la variable CONFIG du fichier .pro, et je pense que plus précisément cela est du à l'option -O2.

Enfin, pour la première valeur de l'accumulateur, je ne pense pas que l'on puisse faire quelque chose avec l'objet foncteur, puisque l'accumulateur est passé par référence comme premier argument de l'operateur (). Par contre, on pourrait créer son propre type d'accumulateur avec un constructeur par défaut qui initialise sa valeur comme on veut. Est ce qu'il existe en C++ une classe Integer comme en Java, et dont on pourrait faire une sous classe avec une valeur par défaut à 1 à la place de 0 ? Je ne pense pas mais on ne sais jamais, et puis le problème c'est que ce n'est pas très flexible. Si quelqu'un à une meilleure solution, je suis preneur.

Merci pour les réponses en tout cas.

**yan** · 16/02/2010, 20h21

ha oui j'ai oublié de dire. Une référence const sur un double, int & co ca sert à rien.
Car une ref c'est en gros un pointeur et que ces type sont de la même taille ou plus petit qu'un pointeur.
Je pense que c'est ton warning.

Envoyé par Le Mérovingien

Enfin, pour la première valeur de l'accumulateur, je ne pense pas que l'on puisse faire quelque chose avec l'objet foncteur, puisque l'accumulateur est passé par référence comme premier argument de l'operateur (). Par contre, on pourrait créer son propre type d'accumulateur avec un constructeur par défaut qui initialise sa valeur comme on veut. Est ce qu'il existe en C++ une classe Integer comme en Java, et dont on pourrait faire une sous classe avec une valeur par défaut à 1 à la place de 0 ? Je ne pense pas mais on ne sais jamais, et puis le problème c'est que ce n'est pas très flexible. Si quelqu'un à une meilleure solution, je suis preneur.
.

Il n'y as pas de classe integer de base en C++.
Par contre, je n'ai pas compris ton problème....

**yan** · 17/02/2010, 09h33

Je viens de comprendre

Tu as raison, vue que le foncteur est copié, je ne voie pas comment tu pourrais utiliser le foncteur pour initialiser la première valeur.

Une bonne solution est surement ce que tu dit. Mais comment initialiser par un float la première valeur?
Un int tu peut faire une template trés simplement. Mais avec un float...

**Le Mérovingien** · 17/02/2010, 09h35

Envoyé par yan

ha oui j'ai oublié de dire. Une référence const sur un double, int & co ca sert à rien.
Car une ref c'est en gros un pointeur et que ces type sont de la même taille ou plus petit qu'un pointeur.
Je pense que c'est ton warning.

C'est vrai, j'ai supprimé tous les const [double|int] &, mais les warning restent. J'ai regardé dans le code source de Qt mais je ne comprends pas plus, parce que je ne sais pas quel objet est réellement manipulé par le pointeur y en question.

Il n'y as pas de classe integer de base en C++.
Par contre, je n'ai pas compris ton problème....

Mon problème, c'est que plutôt que de faire la somme des puissances, j'aimerai faire le produit. Et l'élément neutre du produit, c'est 1, pas 0 comme pour la somme, donc si je remplace le += par un *= dans Somme::operator(), le résultat est toujours 0 à la fin. Je pense que c'est parce que mappedReduced appelle le constructeur par défaut de l'objet qui sert d'accumulateur avant d'y ajouter la première valeur mappée. Comme dans mon cas c'est un double, la valeur par défaut est 0. Mon problème, c'est que j'aimerais pouvoir passer un objet déjà initialisé, un double avec la valeur 1 dans cet exemple. Et je ne vois pas comment faire, à part définir moi même une structure qui contient un double et qui l'initialise à 1 dans le constructeur par défaut. Seulement c'est pas super parce que dans un cas général, ça veut dire que la valeur initiale doit être écrite en dur dans le code, puisque c'est la valeur par défaut

. Voilà, j'espère avoir mieux expliqué, sinon dites moi et je recommence avec plaisir

.

**Le Mérovingien** · 17/02/2010, 09h41

Mon message précédent ne prenait pas en compte ta dernière réponse

, je suis trop lent

.

Envoyé par yan

Un int tu peut faire une template trés simplement. Mais avec un float...

Est ce que tu peux me montrer comment ? je ne vois pas du tout et ça m'intéresse beaucoup. Et il y a une différence entre un int et un float dans l'utilisation ? On ne peut pas faire avec un foat ce qu'on peut faire avec un int ?

Merci pour tout

**yan** · 17/02/2010, 10h10

Envoyé par Le Mérovingien

Est ce que tu peux me montrer comment ? je ne vois pas du tout et ça m'intéresse beaucoup.

moi aussi donc je viens de faire deux trois test

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
#include <QApplication>
#include <QtConcurrentMap>
#include <QList>
 
//struct Puissance;
struct Puissance {
    Puissance(const int& p) : m_p(p) {}
 
    Puissance() {qDebug()<<"Puissance";}
    Puissance(const Puissance & p) {m_p =p.m_p; qDebug()<<" Puissance(const &)";}
    Puissance &operator=(const Puissance & p){m_p =p.m_p;qDebug()<<"Puissance operator="; return *this;}
 
    typedef double result_type;
    double operator() (const double & n) { int i = m_p; double r = 1.; while(i-->0) r*=n; return r; }
    int m_p;
};
 
//struct Somme;
struct Somme
{
    Somme() {qDebug()<<"Somme";}
    Somme(const Somme & ) {qDebug()<<" Somme(const &)";}
    Somme &operator=(const Somme & ){qDebug()<<"Somme operator="; return *this;}
 
    void operator() (double & res, double  n) {res *= n ; }
};
 
void somme(double & result, double  n) { result += n; }
 
 
template<int N>
struct tdouble
{
    double t;
    tdouble(){t = N;}
    operator double&(){return t;}
};
 
#define DOUBLE(x)struct lDouble \
{ \
    double t; \
    lDouble(){t = x;} \
    operator double&(){return t;} \
};
 
 
 
 
 
int main(int argc, char** argv)
{
  QApplication app(argc, argv);
 
  QList<double> l;
  l << 1 << 2 << 3 << 4;
  qDebug() << l;
 
  Puissance p(8);
  Somme s;
 
  {
    DOUBLE(0);
    QFuture<lDouble> res = QtConcurrent::mappedReduced<lDouble>(l, p, s,QtConcurrent::SequentialReduce);
    res.waitForFinished();
    qDebug() << res.result().t;
  }
  {
    DOUBLE(1.2);
    QFuture<lDouble> res = QtConcurrent::mappedReduced<lDouble>(l, p, s,QtConcurrent::SequentialReduce);
    res.waitForFinished();
    qDebug() << res.result().t;
  }
 
  QFuture<tdouble<0> > res = QtConcurrent::mappedReduced<tdouble<0> >(l, p, s,QtConcurrent::SequentialReduce);
  res.waitForFinished();
  qDebug() << res.result().t;
 
  QFuture<tdouble<1> > res2 = QtConcurrent::mappedReduced<tdouble<1> >(l, p, s,QtConcurrent::SequentialReduce);
  res2.waitForFinished();
  qDebug() << res2.result().t;
 
  //QFuture<double> res = QtConcurrent::mappedReduced(l, p, somme);
 
 
  return 0;
}

j'ai fait façon :
une template dans le cas d'un int.
une macro dans le cas d'un double. cette macro définie une struct locale lDouble. Comme tu ne peut avoir plusieur définition, j'utilise les {} pour limité sa porté... C'est pas terrible, mais je voie pas comment faire autrement.

Et il y a une différence entre un int et un float dans l'utilisation ? On ne peut pas faire avec un foat ce qu'on peut faire avec un int ?

les Templates sont exploité lors de la compilation. Comme le double dépend de la machine, il ne peut pas faire des hypothèse comme avec une int.
Tu ne peut donc fixer la valeur d'un float par un paramètre template.

J'était persuadé que la première valeur était initialisé par le premier résultat

**Le Mérovingien** · 17/02/2010, 10h33

Merci, c'est très intéressant je trouve, je ne savais pas qu'on pouvait passer une valeur autre qu'un type dans une template, et pour la macro c'est bien, même si c'est pas super pratique c'est mieux que la structure spéciale avec une valeur par défaut fixe.

J'ai essayé de mon coté la structure Double avec un constructeur par défaut qui place la valeur à 1, ça fonctionne, mais j'ai toujours les même warning de compilation

. Je m'étais dit que peut être en supprimant les types simples ça serait mieux, mais non.

Je trouve que c'est quand même byzarre que les gens de chez Nokia n'ai pas proposé de passer une valeur initiale à l'accumulateur, ou alors ils avaient une bonne raison de ne pas le faire...
En fait cette fonction d'accumulation est équivalente à une fonction "fold" dans les langages fonctionnels (CamL,...), et dans ces langages on peut passer la première valeur de l'accumulateur en paramètre de la fonction. Peut-être dans la prochaine version de Qt...

Merci pour tout, je place le sujet en résolu, car le premier problème est réglé depuis longtemps déjà. Si quelqu'un passe par là et a la solution pour les warning, je suis preneur. Yan, tu ne les as pas quand tu compiles toi ? Si c'est du à GCC...

@++, et merci encore