Discussion :

[Le Mérovingien]

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]

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]

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]

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]

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]

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.