pointeur et Qthread

Version imprimable

01/04/2010, 10h48
tiagocerqueira

pointeur et Qthread

Bonjour je réalise un programme qui utilise la classe QThread de Qt, comme le dit la doc pour que les actions soit réaliser dans la thread, il faut l'allouer dans la thread. c'est ce que j'ai fait et cela fonctionne.

Mon probléme est que quand je fermer le programme il plante en me disant que le pointeur ne peut être désallouer par une autre thread, ma question est comment je fait pour désallouer les pointeur allouer dans la fonction run()

merci d'avance
01/04/2010, 11h12
tiagocerqueira

Juste une précision, j'utilise QTimer pour exécuter une requête TCP en boucle avec QTcpSocket

ça me dit en message debug, que le Qtimer ne peut être arrêter par une autre thread, et aussi que Qtcpsoket ne peut être désactiver par une autre instance?

une idée?? merci
01/04/2010, 11h16
Gulish

tu peux faire ça dans le destructeur de ta classe.

G.
01/04/2010, 11h29
tiagocerqueira

ca marche pas du tout y me dit: QSocketNotifier: socket notifiers cannot be disabled from another thread :(

je montre un peu mon code:

ma fonction run():

Code:

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
 
 
void MyThread::run()
{        
     // création de la socket
    _socket = new QTcpSocket(NULL);
    _socket->moveToThread(this);
 
    //socket Connection
    connect(_socket, SIGNAL(readyRead()), this, SLOT(donneesRecues()), Qt::DirectConnection);
    connect(_socket, SIGNAL(connected()), this, SLOT(connecte()), Qt::DirectConnection);
    connect(_socket, SIGNAL(disconnected()), this, SLOT(deconnecte()), Qt::DirectConnection);
    connect(_socket, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(erreurSocket(QAbstractSocket::SocketError)), Qt::DirectConnection);
 
    //start connection
    ConnectionToPlc();
 
    //creation du timer
    _Timer = new QTimer;
    _Timer->moveToThread(this);    
 
    //Timer Connection
    connect (_Timer, SIGNAL(timeout()), this, SLOT(SendPacket()), Qt::DirectConnection);
 
    //start loop
    _Timer->start(_TimeScale);
 
        exec();
}

mon destructeur:

Code:

1
2
3
4
5
6
7
8
9
 
MyThread::~MyThread()
{
    _Timer->stop();
    _socket->abort();
 
    delete _socket;
    delete _Timer;
}

j'ai essayé comme ca aussi: et ca fonctionne pas

Code:

1
2
3
4
5
6
7
8
9
10
11
12
 
MyThread::~MyThread()
{
    _Timer->moveToThread(this);
    _socket->moveToThread(this);
 
    _Timer->stop();
    _socket->abort();
 
    delete _socket;
    delete _Timer;
}

pouvez-vous m'aider svp

Salut tes moveToThread ne serve à rien dans ton cas.
Si tu alloue dans le run tu désalloue dans le run. C'est aussi simple que cela.

Le top est de faire une classe héritant de QObject qui interface tous tes traitements.

Ensuite tu créé un QThread et tu fait un moveToThread et tu lance le thread.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 class myObject : public QObject { Q_OBJECT /* ................................. */ }; /*...*/ QThread * thread = new QThread; myObject * obj = new myObject; obj->moveToThread(thread ); /*...*/
ps : pour récupérer le QThread courant il faut mieux utiliser
QThread * QThread::currentThread ();

01/04/2010, 14h16
tiagocerqueira

ok merci pour ta réponse, just 2 petite questions par contre:

- Quand tu dis de faire un classe héritant de Q_OJECT ou je fais tout mes traitement, tu veux dire que dans cette classe tu placerai le timer et la socket et que les traitement de la réponse tu le ferai dans une thread a part??

- Aussi si je reste sur mon idée, comment puis-je arréter mon timer et ma socket dans mon run, et les supprimer aussi dans le run, vu que je les utilise tout le temps jusqu'a l'arret du programme???

merci
01/04/2010, 14h31
yan

Citation:

Envoyé par tiagocerqueira

- Quand tu dis de faire un classe héritant de Q_OJECT ou je fais tout mes traitement, tu veux dire que dans cette classe tu placerai le timer et la socket et que les traitement de la réponse tu le ferai dans une thread a part??i

Oui. Depuis Qt 4.4 QThread implémente un run qui lance l'eventloop de la thread.

Citation:

Envoyé par tiagocerqueira

Aussi si je reste sur mon idée, comment puis-je arréter mon timer et ma socket dans mon run, et les supprimer aussi dans le run, vu que je les utilise tout le temps jusqu'a l'arret du programme???

Après le exec().
Cette fonction est bloquante, jusqu'à ce qu tu stop l'eventloop du thread.

ca veut dire que si je fais
Code:

1 2 3 4 5 6 7 8 9 void MyThread::run() { _Timer = new QTimer; connect (_Timer, SIGNAL(timeout()), this, SLOT(SendPacket()), Qt::DirectConnection); _Timer->start(_TimeScale); delete _Timer exec(); }
si je fais ca, jusqu'a que je fasse MyThread::quit();
mon _Timer sera pas supprimé???

01/04/2010, 15h00
yan
J'ai dit aprés ;)
Code:

1 2 3 4 5 6 7 8 9 10 11 void MyThread::run() { _Timer = new QTimer; connect (_Timer, SIGNAL(timeout()), this, SLOT(SendPacket()), Qt::DirectConnection); _Timer->start(_TimeScale); exec(); delete _Timer }
D'ailleurs dans ton exemple autant ne pas faire de pointeur. QTimer sera détruit automatiquement.

Si tu utilise un QObject sans parent, utilise std::auto_ptr au lieu d'un pointeur. Il le détruira de lui même ;)