Discussion :

[DSGSLA]

Bonjour,

Je lance plusieurs threads en parallèle qui travaillent à partir d'une liste. Cette liste est protégée par un QMutex, mais malgré cela mes quatre threads traitent la même première occurrence et ne vident pas la liste.

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
class Thread : public QThread
{
	Q_OBJECT
public:
	Thread(QStringList&, int);
 
 
protected:
	void run();
 
private:
	QStringList Liste;
	int num_thread;
	volatile bool stopped;
	QMutex mutexListe;

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
Thread::Thread(QStringList & list, int i)
{
  stopped = false;
  Liste = list;
  num_thread = i;
}
 
void Thread::run()
{
	qDebug() << "Thread " << num_thread;
 
  forever {
    mutexListe.lock();
    int nb;
    if (!Liste.isEmpty()) {
       QString jobname(Liste.first());
       Liste.removeFirst();
       nb = Liste.size();
       mutexListe.unlock();
       //Mon code QProcess
       qDebug() << "Taille liste = " << nb << "  sur " << num_thread;
       qDebug() << "Lancement " << jobname << " sur " << num_thread;

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
 #include <QApplication>
 
 #include "Thread.h"
 
 int main(int argc, char *argv[])
 {
     QApplication app(argc, argv);
 
  int noeuds(4);
  QStringList Liste;
  Liste << "SCD1LoadDimSSKsFromDimAndFact" << "SCD1LoadFactSSKs" << "SCD1LoadTargetTable" << "SCD1Lookups1" << "SCD1Lookups10" << "SCD1Lookups2";
 
  for (int i(0) ; i < noeuds ; ++i)
  {
  	Thread * un_thread;
  	un_thread = new Thread(Liste, i);
  	un_thread->start();
  }  
 
  return 0;
 }

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
Thread  0
Thread  1
Thread  3
Thread  2
Taille liste =  5   sur  0
Taille liste =  5   sur  1
Taille liste =  5   sur  2
Taille liste =  5   sur  3
Lancement  "SCD1LoadDimSSKsFromDimAndFact"  sur  0
Lancement  "SCD1LoadDimSSKsFromDimAndFact"  sur  2
Lancement  "SCD1LoadDimSSKsFromDimAndFact"  sur  1
Lancement  "SCD1LoadDimSSKsFromDimAndFact"  sur  3

[democrie]

je n'ai jamais fait de multi process....
mais
a priori le mutex empeche plusieurs threads de passer dans le même code.
Or ici tu as une instance de mutex pour chaque thread, donc le lock ne concerne que le thread en question....

Le mutex devrait être mis dans un objet encapsulant ta liste....
les modifications de valeurs seraient alors effectuées par un thread en même temps

à vérifier bien sûr

[DSGSLA]

J'ai mis le mutex dans les données membres du thread comme c'est fait dans le livre Qt4 et C++.
J'ai essayé en mettant le mutex en variable globales mais j'ai une erreur à la compilation.

[Fabllot]

Bonjour,

democrie a raison, mutexListe étant une variable de classe non statique, il en existe autant que d'instance de la classe... donc ton mutex ne sert à rien.

Pour que ce soit correct, il faut mettre mutexListe en static...

Si ça ne compile toujours pas, montre les erreurs...

[yan]

Bonjour,

democrie a raison, mutexListe étant une variable de classe non statique, il en existe autant que d'instance de la classe... donc ton mutex ne sert à rien.

Pour que ce soit correct, il faut mettre mutexListe en static...

C'est une solution.
Par contre,il fait la même erreur avec la liste. Chaque thread à sa propre liste....

[DSGSLA]

Si je mets mutexListe en static j'ai l'erreur de compilation suivante :

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
g++ -enable-stdcall-fixup -Wl,-enable-auto-import -Wl,-enable-runtime-pseudo-rel
oc -Wl,-subsystem,console -mthreads -Wl -o debug\QThread.exe debug/main.o debug/
Thread.o debug/moc_Thread.o  -L"c:\Qt\qt\lib" -lQtGuid4 -lQtCored4
debug/Thread.o(.text+0x542): In function `ZN6Thread3runEv':
L:/CPP/Qt/QThread/Thread.cpp:18: undefined reference to `Thread::mutexListe'
debug/Thread.o(.text+0x5b6):L:/CPP/Qt/QThread/Thread.cpp:24: undefined reference
 to `Thread::mutexListe'
debug/Thread.o(.text+0x1035):L:/CPP/Qt/QThread/Thread.cpp:40: undefined referenc
e to `Thread::mutexListe'
collect2: ld returned 1 exit status
mingw32-make[1]: *** [debug\QThread.exe] Error 1
mingw32-make[1]: Leaving directory `L:/CPP/Qt/QThread'
mingw32-make: *** [debug] Error 2

Pourquoi chaque thread aurait sa liste puisque je passe laliste par référence au constructeur ?