[Multi-threading] Communication d'enregistrements entre threads

Bonjour à tous,


Je vais essayer d'expliquer le plus simplement :

Soient deux thread : thread1 et thread2.
Soit un record :

Code:

---

1 2 3 4 5

monRecord = record heure: TDateTime; distance: integer; sauver: boolean; end;

---

Comment faire pour que thread1 génère un monRecord avec des valeurs définies et qu'il l'envoie à thread2 ?

Je me suis évidemment penché sur la méthode PostThreadMessage mais j'ai du mal à comprendre :
Premier paramètre l'handle de thread2 => ok
Deuxième paramètre => un identifiant de mon message. Est-ce que comme ça c'est bon :

Code:

---

1 2 3

const WM_INFOTHREAD1 = WM_USER + 1;

---

?
Troisième et quatrième paramètre ... Et voila .... je pense bien que c'est par là que je dois mettre mon record .... mais comment ?




Ensuite,
côté thread2, je dois bien, dans ma boucle principale faire simplement appel à PeekMessage ?





Par avance, merci pour votre aide

Je viens de trouver ça -> Spécial Delphi - Michel


Seulement i utilise SendMessage et par conséquent son record existe toujours en mémoire, or moi je voudrais pouvoir utiliser PostMessage (ou PostThreadMessage) pour que thread1 n'attende pas que thread2 ait traité le message (et d'ailleurs ... alors même que thread2 n'a pas traité le message de thread1, je voudrais que thread1 soit capable d'en envoyer d'autres à thread2) ...

Je voudrais en simple, créer une file de message dont le message est un record ...




Merci à quiconque m'aidera

Tu peux aussi générer tes record (via pointeur), et les entreposer dans une TThreadList, consulter celle-ci dans le second thread, et libérer les items traiter ...

c'est nettement moins prise de tête que les messages windows ... qui fonctionne comme ceci :

Code:

---

1 2 3 4 5 6 7

type PBleysThreadRecord = ^TBleysThreadRecord; TBleysThreadRecord = record heure: TDateTime; distance: integer; sauver: boolean; end;

---

Listener

Code:

---

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

var Msg: TMsg; begin while not Terminated do begin Sleep(5); if GetMessage(Msg, 0, WM_INFOTHREAD1, WM_INFOTHREAD1) then begin // Gère Msg S := FormatDateTime('HH:SS:NN', PBleysThreadRecord(Msg.wParam)^.Heure); Dispose(PBleysThreadRecord(Msg.wParam)); // Libération end; end;

---

Sender

Code:

---

1 2 3 4 5 6 7 8 9

var monRecordPtr: PBleysThreadRecord; begin New(monRecordPtr); monRecordPtr^.Heure := Now(); ... PostThreadMessage(HandleThread2, WM_INFOTHREAD1, Integer(monRecordPtr), 0); // Ne plus utilisé monRecordPtr, end;

---

Si tu loupes des messages, on ne sait jamais, je n'ai pas utilisé PostThreadMessage pour des mécanismes essentiels de mes applications, lui préférant la ThreadList, tu peux avoir des fuites mémoires, dans ce cas, stocker les Pointers, et leur affecter une date de péremption pour les libérer ... mais gare au violation d'accès ...

Tu es si bon ShaiLeTroll ... :D



J'avais pensé au TList modifié pour les threads un peu comme le TThreadStringList,
Mais en y réfléchissant bien, ça doit bien exister quelque part tout fait déjà cette unité ...


Je vais me pencher là dessus ... Ce qui évitera de gérer les messages windows, certainement plus lourd à gérer (mais plus performant peut-être ?)



Encore merci à toi

la TThreadStringList, je ne l'a connaissais pas celle là ? c'est depuis quel Delphi ? sinon la TThreadList (Classes.pas), existe depuis au moins Delphi 5 ...

Côté performance, à mon avis, cela ne doit pas changer grand chose sur les machines que nous avons, tant que ta liste ne contient pas quelques milliers d'items ... mais autant le gérer soit-même, autant maîtriser sa mémoire

en général, je fixe une capacity à 1024 messages, puis lorsque cela approche de ce chiffre, je lance un Pack(), car je ne fais pas de delete sur la liste, mais j'affecte nil, ainsi cela reduit les mouvements en mémoire ...

La TThreadStringList je l'ai trouvé sur internet en fait ... sur un tuto de développez d'ailleurs ...

Quand à TThreadList, malheureusement pour moi je suis sous Delphi 4 ... du coup je l'ai ré-implémenté ... ou tout du moins, ce qui m'intéressait ....



Merci pour tout ;) et je prends note pour ta remarque de fin

Je devais vraiment être dans les vappes ce jour là ... TThreadList existe bien sous Delphi 4 ... Pourquoi ne me l'avait-il pas trouvé avant ? :aie: Mystère ...


Dommage ... je préférais la version que j'avais implémenté ... mais bon tant pis :)



Merci pour tout