Discussion :

[DSGSLA]

Bonjour,

J'ai connecté tous les threads créés avec la classe appelante. J'ai un emit et un slot personnalisés.

Le code compile et passe bien sur l'emit mais la fonction slot ne semble jamais être appelée.

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
 class Compil : public QObject
{
	Q_OBJECT
 
public:
	Compil(QStringList* );
 
 
private slots:
      void showProgress();	
 
 
};

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
Compil::Compil(QStringList* ListeJob)
{
 
qDebug() << "Classe Compil";
 
 
  QStringList * ListeStdOut = new QStringList ();
  QStringList * ListeStdErr = new QStringList ();
 
  QList<Thread*> threadList;
 
  int noeuds(4);  
 
  for (int i(0) ; i < noeuds ; ++i)
  {
  	Thread * pThread = new Thread(ListeJob, ListeStdOut, ListeStdOut, i);
  	QObject::connect(pThread, SIGNAL(compilationFinished()),this, SLOT(showProgress()));
  	pThread->start();
  	threadList << pThread;
  }  
 
    while (threadList.count () > 0) {
      threadList[0]->wait ();
      delete threadList[0];
      threadList.removeFirst ();
   }
 
   delete ListeJob;
   delete ListeStdOut;
   delete ListeStdErr;
}
 
 void Compil::showProgress()
 {
  qDebug() << "SIGNAL" ;	
 }

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
Thread::Thread(QStringList * liste_job, QStringList * liste_StdOut, QStringList * liste_StdErr, int i)
{
  ListeJob = liste_job;
  ListeStdOut = liste_StdOut;
  ListeStdErr = liste_StdErr;
  num_thread = i;
}
 
void Thread::run()
{
	qDebug() << "Thread " << num_thread;
 
  forever {
 
     (...)
 
       qDebug() << "emit";
       emit compilationFinished();
    }
    else {
          mutexListeJob.unlock();
          break;
    }
  }
}

[johnlamericain]

Ma première impression mais c'est peut être une bétise

Lorsque tu fais un emit, le signal est placé dans une file d'attente avant d'être reçu et d'exécuter le slot.

Cependant tu détruit l'objet emettant le signal immédiatement après emission de celui-ci, donc si il n'est pas dépilé de la file d'attente avant la destruction de ton thread, il est perdu.

En effet si il y a destruction d'un des deux objets (emetteur ou receveur) d'un connect, il y a obligatoirement un disconnect de fait.

[DSGSLA]

L'emit est dans une boucle forever des threads. Le thread n'est pas détruit avant l'émission du signal. Ma log me montre que le code passe plusieurs fois sur l'emit avant la destruction d'un thread.

[Niak74]

Mets plus de traces pour savoir où est l'impasse.

De plus, cette partie me semble étrange :

while (threadList.count () > 0) {
threadList[0]->wait ();
delete threadList[0];
threadList.removeFirst ();
}

Tu supprimes tout tes threads juste après leur création. De plus, il est mieux de s'assurer qu'un thread soit fini avant de le tuer brutalement.

[DSGSLA]

Quand les threads ont terminé leur travail je les détruits, je ne vois pas le problème.

[Niak74]

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
for (int i(0) ; i < noeuds ; ++i)
  {
  	Thread * pThread = new Thread(ListeJob, ListeStdOut, ListeStdOut, i);
  	QObject::connect(pThread, SIGNAL(compilationFinished()),this, SLOT(showProgress()));
  	pThread->start();
  	threadList << pThread;
  }  
 
    while (threadList.count () > 0) {
      threadList[0]->wait ();
      delete threadList[0];
      threadList.removeFirst ();
   }

Description de la fonction wait : http://qt.developpez.com/doc/latest/qthread/#wait

Tu n'attends pas que les Threads puissent vivre entre les bloc for et while.
Tu n'attends pas non plus que les Threads se terminent entre le wait et le delete.

EDIT :

de plus concernant :

Code :

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

1
2
3
delete ListeJob;
delete ListeStdOut;
delete ListeStdErr;

Il est inutile d'allouter dynamiquement les objets conteneurs de type QList (et donc, QStringList), QVector dans ton cas, et de manière générale.

Explications : COW http://qt.developpez.com/doc/latest/...ist-of-classes

Il est aussi très déconseillé d'allouer et de désallouer des variables dans des fonctions différentes (cas ici pour ListeJob).

[johnlamericain]

L'emit est dans une boucle forever des threads. Le thread n'est pas détruit avant l'émission du signal. Ma log me montre que le code passe plusieurs fois sur l'emit avant la destruction d'un thread.

Je suis d'accord, je pense que le thread n'est pas détruit avant l'emission du signal, mais qu'il est détruit avant la reception

http://qt.developpez.com/doc/latest/...ctiontype-enum

[DSGSLA]

Merci, avec l'option facultative Qt::DirectConnection dans le connect ça marche.