Communication entre des threads

Bonjour à tous,
Je suis entrain de développer un logiciel sous Visual Studio en C++ à base de fenêtres Dialog.
Je souhaite communiquer entre une fenêtre et un processus lancer à partir de celle-ci.
Je lance le processus de la façon suivante :

Code:

---

1 2 3

CRuntimeClass* m_pThread = RUNTIME_CLASS(TagDetectThread); AfxBeginThread(m_pThread,THREAD_PRIORITY_NORMAL,0,0,NULL);

---

TagDetectThread étant la classe qui contient le processus.
Je comptais utiliser les fonctions suivantes mais je n'arrive pas a les faire fonctionner :
PostThreadMessage
RegisterWindowMessage
ON_REGISTERED_THREAD_MESSAGE

A la suite d'un "click" sur un bouton, je veux déclencher la fin du thread.
J'utilise donc la fonction suivante :

Code:

---

1 2 3 4

DWORD ID; ID = (ULONG)GetCurrentThreadId; PostThreadMessage(ID,WM_QUIT,0,0);

---

Dans la classe comportant mon thread, j'ajoute juste après la boite de message :

Code:

---

1 2	[i]ON_THREAD_MESSAGE(WM_QUIT,Run) // Run étant la fonction du thread

---

Dans cette fonction Run, je met une fonction de détection de cette forme :
MSG msg;

Code:

---

1 2	if(GetMessage(&msg,NULL,0,0)<0) AfxMessageBox("Error");

---

Malheureusement elle ne fonctionne pas. Etant donné que je débute en MFC - C++, je ne comprends pas pourquoi celà ne marche pas ?
Ais-je oublié quelque chose ? Y a-t-il quelque chose de mal défini ?
Merci beaucoup pour votre aide.

utilise la balise code, Merci Farscape

Salut,

supposition (1):
Tu dis que tu "lance le processus", donc ce doit être un exécutable.
Ce que tu peux faire:
Tu déclare une variable membre qui sera le handle de ton processus lancé avec ( supposition tjrs ) CreateProcessus( ) lors d'un clic sur un bouton de commande par exemple.
Lorsque tu voudras le manipuler avec les autres fonction de l'API, tu pourras tjrs te servir du handle du processus.

supposition (2):
Tu parles aussi de Thread, donc là on est "plus" ds une fonction.
Pareil que ci-dessus, mais avec CreateThread( ).

Si tu as la MSDN, faire un F1 sur CreateProcessus et CreateThread qui t'expliquera les autres fonctions de manipulation des processus/thread.

C'est pas du pur MFC ( plutôt de l'API Win32 ) mais ça peut te sortir d'affaire.

:D

Déjà, ton thread est-il un vrai thread UI, avec boucle de messages et tout, ou bien un thread qui fait un traitement et qui n'est pas supposé avoir de boucle de messages ?

Je ne vois pas trop ce que tu entends par Thread UI, mais en gros la classe TagDetectThread est dérivée d'une classe CWinThread, et elle comporte une partie réception des messages (avec AFX) et une instance RUN dans laquelle j'ai mis le code a executer par le thread.
Concernant la fonction de ce thread, il doit juste se terminer quand on lui demande et s'intérompre sur demande. Après je en sais pas si celà nécéssite forcément une boucle de message.


Pour Denn's, je suis dans la supposition (2) et je n'ai pas de problème pour lancer le thread. Je cherche a savoir comment lui faire prendre en compte un message qui vient d'une classe CDialog.
Le problème n'est pas de savoir quelles sont les fonctions dont j'ai besoin, mais plutôt comment les faires fonctionnées ?

Ce que tu me décris, c'est un thread UI.

C'est donc le genre de thread que tu peux terminer avec un PostThreadMessage(WM_QUIT, etc.) ou avec un message "registered" dans le traitement duquel tu appellerais PostQuitMessage().

Généralement, je laisse l'EDI généré automatiquement les handlers pour les messages enregistrés pour les fenêtres, mais j'ignore si ça marche pour les CWinThread aussi (et j'en doute...)

Effectivement ca marche bien pour les fenêtres mais pour les threads je ne crois pas que ça soit possible. Ca va être dur d'avancer dans ces conditions ...

Au pire, tu utilises l'assistant pour un message Registered à une fenêtre, puis tu adaptes au thread (usage de la macro, fonction avec retour void, etc.)

Citation:

---

Envoyé par Analog13

Je ne vois pas trop ce que tu entends par Thread UI

---

UI pour User Interface -> un thread d'interface utilisateur. A différencier avec le "worker thread" pour thread de travail.

En gros, le premier traitre tout ce qui est interaction avec l'utilisateur (événement souris, raccourcis claviers, menu etc...) et le second est utilisé pour effectuer une tache/opération particulière (E/R de données, calcul etc...).

;)

C'est plutot un Worker Thread qui sert à faire un scan en continu.
Je n'ai toujours pas trouvé comment l'arrêter.
Le problème est que je n'arrive pas à faire le lien entre la classe qui le créé, et le thread proprement dit.
Je pense que celà vient du fait que ce sont deux fichiers distincts et que le message privé ne se transmet pas de l'un vers l'autre.
Depuis que je fais des recherches, j'ai trouvé beaucoup d'exemples, mais aucun n'est vraiment clair pour un débutant.
Est ce que vous pouvez m'indiquer comment transmettre un message de ma CDialog vers mon thread ?

Bonjour,

Quand tu ecrits ça:

Code:

---

1 2 3

DWORD ID; ID = (ULONG)GetCurrentThreadId(); PostThreadMessage(ID,WM_QUIT,0,0);

---

C'est pas l'ID du thread appelant qu'il faut, mais l'ID du thread appelé.
Et l'ID tu le trouves ici:

Code:

---

1 2 3 4 5 6 7 8

CWinThread *pThread=AfxBeginThread(....); // création du thread   // Faut conserver le pointeur pThread pour l'utiliser dans CDialog   // Dans CDialog:   DWORD ID=pThread->m_nThreadID; PostThreadMessage(ID,WM_QUIT,0,0);

---

Mais comme dit plus haut c'est lourd d'utiliser la pompe à message pour faire ce genre de synchronisation surtout s'il n'y a pas d'interface utilisateur (UI = fenetres ...)

Regarde plutot ici:
http://developpez.net/forums/showthread.php?t=390750

@+

Il y a une interface utilisateur mais pour l'instant elle n'agit pas sur le thread mis a part déclencher son arrêt.
Une fois que j'aurai réussi à faire fonctionner l'arrêt du thread, il faudra que je trouve un moyen d'échanger des données entre ma classe "de base" et mon thread. Mais chaque chose en son temps.

En ce qui concerne la boucle de message, il vaut mieux utiliser un Get ou un PeekMessage ?

Quand je parlais d'interface utilisateur, c'est une interface propre au nouveau thread, c'est a dire : une interface dans le thread d'origine et une autre interface dans le nouveau thread.

Là je crois que tu melanges tout :mouarf:

Tu as deux types de thread:

* les worker threads --> c'est simplement une fonction qui est appelé, quand la fonction fait un 'return' le thread est fini. Apres dans cette fonction tu fais ce que tu veux, mais tu ne touches surtout pas aux fenetres windows. (car il n'y a pas de file à message de créé)

* les UI threads --> c'est un thread avec une file à message. De là tu peux créer et gérer des fenetres comme dans une appli classique. Mais attention, une fenetre créée dans un thread ne peut pas etre manipulée par un autre thread (si, mais c'est limitée) --> confinement de la fenetre dans le thread qui l'a créée.

Si ton thread n'a pas l'intention de créer des fenetres, utilises un worker thread.

Si tu utilises un UI Thread, il faut surcharger les fonctions InitInstance() et ExitInstance() de CWinThread et y mettre ton code d'initialisation / nettoyage. --> dans InitInstance(), tu créées ta fenetre principale.

La pompe a message est gérée par les MFC.

Si ton thread n'a pas de fenetre, tu peux qd meme utiliser la file de message par l'intermediaire de la fonction PostThreadMessage(), et y mettre un gestionnaire coté thread (ON_THREAD_MESSAGE). Mais c'est lourd si c'est utilisé que pour des messages privés.

Pour les échanges de données, tu peux utiliser une simple zone mémoire, mais il faut que tu 'serialises' les accès --> un seul thread ne doit pouvoir accèder aux données a la fois. --> mettre en place un mutex, ou une critical section.


PS: le message WM_QUIT n'est jamais envoyé a son gestionnaire puisqu'il sert a sortir de la boucle à message. Met plutot ton code de fin de thread dans ExitInstance() ou créé un message privé (WM_USER+xxx)

@+

Merci pour cet éclaircissement limpide.
Il s'agit donc bien d'un Worker Thread.
Quand tu dis que c'est lourd d'utiliser la file de message, tu utilises quoi à la place ?
Une fois que le lien est fonctionnel (enfin il semble l'être) comment fait on pour récupérer le message ? J'ai essayer d'utiliser GetMessage ou PeekMessage sans résultat ?? Peut être que celà fonctionne en se servant d'un WaitForSingleObject ?

Est ce que l'utilisation d' AfxMessageBox dans le thread perturbe la distribution des messages ?

Il existe de tutoriaux pour les Mutex ou Critical section ?

Pour la boucle de message, comment faire pour que l'execution ne soit pas bloqué en attendant un éventuel message ?

Voilà ce que j'ai utilisé :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21

#define WM_STOP 100 ... ON_THREAD_MESSAGE(WM_STOP,Run) ...   int TagDetectThread::Run() { MSG msg;   while(GetMessage(&msg,NULL,0,0) { if(msn.message==WM_STOP) { AfxMessageBox("Stop The Thread"); break; } }   ... }

---

Le problème c'est qu'il ne se passe rien tant que je n'envoi pas le message.
Je souhaiterai rentrer dans la boiucle que lorsque l'on a envoyé un message.
Comment procède-t-on ?

Bonsoir,

Tu n'as pas a reecrire la boucle a message, elle est deja implementée par les MFC.

En clair, tu mets ton code d'initialisation dans InitInstance() que tu as surchargé (fonction virtuelle de CWinThread). Et ton code de nettoyage dans ExitInstance(). (idem)

C'est tout.

Et entre le BEGIN_MESSAGE_MAP() et le END_MESSAGE_MAP(), tu déclares tes gestionnaires avec ON_THREAD_MESSAGE(...)

Inutile de mettre un gestionnaire pour WM_QUIT, ce message n'est jamais dispatché (par DispatchMessage()), il sert de sentinelle pour sortir de la boucle à message.

@+

C'est bon j'ai trouvé une structure sembalble à celle que j'ai décrite hier, qui me permet d'arrêter le thread ou plutôt la boucle qu'il comporte.
Si c'est possible, je souhaiterai avoir des infos sur ce dont parlait stephdim :

"Pour les échanges de données, tu peux utiliser une simple zone mémoire, mais il faut que tu 'serialises' les accès --> un seul thread ne doit pouvoir accèder aux données a la fois. --> mettre en place un mutex, ou une critical section."

Comment est ce qu'on met en place ce genre de zone mémoire ?
Quel est le moyen le plus simple de transférer des données entre le hread et la fenêtre qui le commande ?

salut,
dans le cas d'un thread de travail ,le sens de communication naturel est le thread vers l'interface.
un message privé vers l'interface peut faire l'affaire.
il faut aussi savoir que normalement on ne peut pas accéder aux objets MFC graphiques a partir d'un thread de travail, d'ou l'utilisation d'un message privé à l'interface.
en fait ceci est vrai en debug, en release l'accès direct fonctionne même si ce n'est pas la méthode recommandée par MS.
dans le cas de plusieurs thread tu peux utiliser un mutex pour acceder aux données:
http://www.developpez.net/forums/sho...ighlight=mutex

OK merci pour cet éclaircissement.
Mais est ce que l'utilisation d'un message privé peut être valable pour transférer (ou accèder à) un tableau de structures ?
Dois-je utiliser un mutex ? Faire un passage par pointeur ??

l'accès au tableau doit être protégé par le mutex.
le tableau peut être une variable globale ou contenu dans un singleton.
http://c.developpez.com/faq/vc/?page...GlobalVarInMFC
dans ce contexte pas besoin de message, c'est juste un partage de données sécurisées.

Finalement, j'ai utilisé un buffer commun pour que la fenêtre puisse accèder aux données.
Maintenant, j'ai un problème de communication entre mon thread et ma fenêtre.
Je m'explique. Mon thread envoi un message à ma fenêtre pour faire une sorte de rafraichissement de l'affichage. Le problème est que je n'arrive pas a récuperer le message.

Pour le récupérer, j'utilise une fonction timer pour venir analyser la boucle de message régulièrement, afin de voir si l'on a reçu le message d'affichage.
Mais celui-ci n'arrive jamais.

Voilà mon code :
Pour l'envoi du message depuis le thread :

Code:

---

1 2 3 4

#define WM_SHOW 103   PostMessage(HWND_BROADCAST,WM_SHOW,0,0);

---

Pour la réception depuis la fenêtre :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16

void OnTimer(UINT nIDEvent) { Display(); CDialog::OnTimer(nIDEvent); }   void Display() { MSG msg; PeekMessage(&msg,NULL,0,0,PM_REMOVE); if(msg.message==WM_SHOW) { //Affichage } }

---

Si je mets une boucle d'attente comme celle là à la place de PeekMessage, le message est bien détecté mais la boucle est quasi-infini et l'application utilise toute la resource cpu.

Boucle d'attente :

Code:

---

1 2 3 4 5

while(msg.message!=WM_SHOW) { PeekMessage(&msg,NULL,0,0,PM_REMOVE); }

---

Est ce que j'utilise convenablement PeekMessage ?
Je suppose qu'il faut utiliser une autre méthode de synchronisation, mais comment procèder ? Sémaphore ?

Salut,
Ton appli possède déjà une boucle de message, tu dois utiliser celle-ci pour intercepter ton message user.

Pour ma part je ferais comme ceci

Code:

---

1 2 3 4 5 6 7 8 9 10 11

#define WM_USER_SHOW (WM_USER+0x01) // à définir des deux cotés   BEGIN_MESSAGE_MAP() .... ON_MESSAGE(WM_USER_SHOW , OnUserMsgShow) ... END_MESSAGE_MAP()   LRESULT OnUserMsgShow(WPARAM wParam, LPARAM lParam) {...}

---

.h

Code:

---

1 2 3

afx_msg LRESULT OnUserMsgShow(WPARAM wParam=0, LPARAM lParam=0);

---

Ok mais comment faire pour pouvoir lancer une fonction existante à partir de cette fonction de détection de message ?
Ma fonction n'est plus reconnue à l'intérieur de cette entité.

En plus, le compilateur n'a pas l'air d'apprécier cette fonction.
-> Error LNK2001 : unresolved external symbol "public: long __thiscall DemokitS::OnUserMsgShow(unsigned int,long)" ...

Citation:

---

Envoyé par Analog13

Ok mais comment faire pour pouvoir lancer une fonction existante à partir de cette fonction de détection de message ?
Ma fonction n'est plus reconnue à l'intérieur de cette entité.

---

voir faq: http://c.developpez.com/faq/vc/?page...PrivateMessage

Même en suivant le tutorile (ce que j'avais déjà fait), celà ne fonctionne toujours pas. Il y a toujours la même erreur.
Il n'existe pas un moeyn d'avoir une sorte de synchronisation, quand on reçoit le message privé, pour que celui-ci soit interprété directement ?

si ça fonctionne ... , tu dois te tromper dans ton implementation,
montre ton message d'erreur.

C'est exactement le même que celui que j'ai écris juste avant.
Error LNK2001 : unresolved external symbol "public: long __thiscall DemokitS::OnUserMsgShow(unsigned int,long)"

hé bien dans ce cas:
tu n'as pas implementé la fonction OnUserMsgShow(unsigned int,long) dans la classe DemokitS.

Celà signifie que je n'ai pas écris son code à l'intérieur de ma classe, c'est ça ?
Pourtant, j'ai mis :

Code:

---

1 2 3 4 5 6

long OnUserMsgShow(WPARAM wparam,LPARAM lparam) { AfxMessageBox("Display"); return 0; }

---

Si ce n'est pas ça, je crois que j'ai encore besoin d'explications.

Le second problème, c'est que je ne peux pas lancer ma fonction d'affichage depuis OnUserMsgShow car elle n'est pas reconnue ???

Code:

---

1 2 3 4 5

long DemokitS::OnUserMsgShow(WPARAM wparam,LPARAM lparam) { AfxMessageBox("Display"); return 0; }

---

Effectivement c'était bien ça en ce qui concerne cette erreur de compilation. Bien vu. Merci beaucoup pour votre aide.

Par contre, la fonction OnUserMsgShow n'est jamais lancée par l'application.
Soit le message n'arrive pas, soit il y a autre chose ??

Alors vous n'avez pas d'idées d'où ça pourrait venir ?
On dirai que le message n'est jamais redirigé vers la fonction OnUserMsgShow.
Le problème c'est que je ne vois pas vraiment ce qui manque pour que ça soit le cas ?

Citation:

---

Envoyé par Analog13

Alors vous n'avez pas d'idées d'où ça pourrait venir ?
On dirai que le message n'est jamais redirigé vers la fonction OnUserMsgShow.
Le problème c'est que je ne vois pas vraiment ce qui manque pour que ça soit le cas ?

---

que le handle de fenêtre spécifié dans le message ne soit pas correcte ...

C'est un handle "universel" pour que le message soit envoyé à tout le monde et pour éviter ce genre de problème.

Code:

---

PostMessage(HWND_BROADCAST,WM_USER_SHOW,0,0);

---

Cette méthode fonctionnait avec mon précédent code, donc je ne vois pas pourquoi ça ne serai plus le cas ?

HWND_BROADCAST est envoyé aux fenêtres de premier niveau pas aux fenêtres filles .

Ma fenêtre n'est pas une fenêtre fille, et comme je l'ai dis précédement, cette méthode de transmission de message fonctionnait très bien (cf message #20).
Il faut peut être utiliser une autre solution ?

Citation:

---

Envoyé par Analog13

Ma fenêtre n'est pas une fenêtre fille, et comme je l'ai dis précédement, cette méthode de transmission de message fonctionnait très bien (cf message #20).
Il faut peut être utiliser une autre solution ?

---

appliquer correctement la méthode indiquée dans la faq...

il ne faut pas tout mélanger et bien comprendre ce qu'on utilise:
Ta méthode (pas terrible) fonctionnait parce que tu as implémenté une pompe à message qui donc intercepte tous les messages destinés à l'application rien de plus.
vu comme ça c'est sûr ça fonctionnait, tu as juste court circuité le mécanisme d'acheminement des messages aux fenêtres...

C'est tout de suite plus clair avec quelques explications.
Et ça marche beaucoup mieux.