Partage variable entre Threads

Version imprimable

Voir 40 message(s) de cette discussion en une page

06/04/2011, 12h27
fiberMan

Partage variable entre Threads

Bon,
J'ai une application Client/Serveur,
Coté client j'ai utilisé un thread (ReceivePacket) qui reçoit le message venant du serveur. J'utilise Windows.Form pour l'interface. Le probleme c'est que le compilateur me prévient d'invalidité d'utilisations des objets entre thread quand je fais appele aux composants des Form (SplitContainer, ....) dans le thread (ReceivePacket), Or j'ai déjà partagé l'objet au moyen de XX.start(ObjetApartager)???
Est quelqu'un aura un idée de cause de cette problème?
06/04/2011, 13h31
DarkHerumor

Je ne suis pas sur de tout à fait comprendre ce que tu cherches à faire.

Pour faire "dialoguer" deux classes dans des threads différents, tu peux utiliser les délégués, et la méthode Invoke.

Si tu as une variable/propriété partagée entre deux threads, tu peux faire un lock, pour en assurer la sûreté d'accès.
06/04/2011, 13h42
fiberMan

C'est la deuxième proposition qui me semble très utile.
Mais que fait exactement lock?
06/04/2011, 13h48
DarkHerumor
Je vais essayer de ne pas dire de bétises :)

En gros, lock interdit à deux thread de venir dans le bout de code concerné en même temps. Et à la place créer une liste d'attente.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 int GetCount() { lock(_list) { return _list.Count; } } void Add(object item) { lock(_list) { _list.Add(item); } }
En faisant cela, tu t'assure qu'aucun thread ne viennent ajouter des données dans _list, pendant que tu compte ce qu'il y a dedans.
De plus deux thread ne peuvent ajouter en même temps des données dans _list.
06/04/2011, 13h51
Arnard

Tu partages des objets graphiques (Form ==> Winform ?) entre threads ? Dans ce cas là je t'arrête, il ne doivent être manipulés que depuis le thread UI ! D'où le message indiquant que ce composant appartient à un autre thrad !
06/04/2011, 14h01
fiberMan

Citation:

Envoyé par Arnard

Tu partages des objets graphiques (Form ==> Winform ?) entre threads ? Dans ce cas là je t'arrête, il ne doivent être manipulés que depuis le thread UI ! D'où le message indiquant que ce composant appartient à un autre thrad !

Donc que faire alors? Mon but c'est de rendre visible le SplitContainer + TreeView + ListView quand le client reçoit des messages ACK venant du serveur car je compte le traiter dans la deuxième thread (ReceivePacket)
06/04/2011, 14h46
Nathanael Marchand

Le multi thread avec une UI est un peu particulier. Lorsqu'un thread en arrière plan souhaite effectuer une modification sur un objet de l'UI, il faut qu'il ajoute ca à la liste des taches à faire pour le thread de l'UI. Il suffit de récuperer une instance de contrôle comme par exemple myForm (une instance d'un formulaire) :

Code:

myForm.Invoke(()=>{myCheckbox.Checked=true;});

A noter que dans le délégué il ne faut executer que du code de rafraichissement de l'ui, sinon tu freezes ton ui.
06/04/2011, 14h53
DonQuiche

Bonjour, en utilisant Control.Invoke/BeginInvoke (ou le Dispatcher pour WPF).

EDIT : Oups, trop tard.
06/04/2011, 15h33
fiberMan

Citation:

Envoyé par Nathanael Marchand

Le multi thread avec une UI est un peu particulier. Lorsqu'un thread en arrière plan souhaite effectuer une modification sur un objet de l'UI, il faut qu'il ajoute ca à la liste des taches à faire pour le thread de l'UI. Il suffit de récuperer une instance de contrôle comme par exemple myForm (une instance d'un formulaire) :

Code:

myForm.Invoke(()=>{myCheckbox.Checked=true;});

A noter que dans le délégué il ne faut executer que du code de rafraichissement de l'ui, sinon tu freezes ton ui.

Donc j'utilise mon thread, avec partages des Objets entre thread avec Start et où je met cette fonction

Code:

myForm.Invoke(()=>{myCheckbox.Checked=true;});
06/04/2011, 22h39
DonQuiche

Tu places tout simplement cette ligne à l'endroit où tu avais normalement écrit "myCheckbox.Checked = true" dans ton worker thread.

Considère Invoke/BeginInvoke comme un wrapper à utiliser pour effectuer une action UI depuis un autre thread que celui de l'UI : ces méthodes forcent l'exécution du délégué spécifié sur le thread UI plutôt que sur le thread appelant.

C'est un pattern qui élimine tout besoin de synchronisation en garantissant que tout accès fait depuis un autre thread que l'UI lèvera une exception. Ses forces sont sa simplicité de conception et d'utilisation, ses faiblesses sont un impact sur les performances et/ou la réactivité plus important qu'un système traditionnel bien conçu et bien utilisé.

PS : l'objet fourni en argument à Thread.Start est simplement un paramètre fourni à la méthode de ton thread, il ne bénéficie aucunement d'un quelconque traitement particulier qui assurerait une synchronisation lors d'un accès parallèle par deux threads. C'était peut-être clair pour toi mais à la relecture de certaines de tes phrases je me suis dit que tu avais peut-être compris cela de travers. Au cas où...

Merci pour pour l'aide, mais pour être clair (je suis un peu débutant en C Sharp).Est que vous pouvez illustrer par des exemples de codes.
Voici mon code Thread "ReceivePaquet" que je doit utiliser l'objet SplitContainer de l'UI :

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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
 
 //Methode de Connection au serveur
        public static void  startConnectionServer(String ipAddres)
        {
            try
            {
                Thread threadMessageReceive = new Thread(receiveMessageTreat);
                serveur = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
                serveur.Connect(new IPEndPoint(IPAddress.Parse(ipAddres), 7777));
 
                msgOut = ASCIIEncoding.Default.GetBytes(Protocole.DEMAND_CONNECTION);
                //Demande Authorisation
                serveur.Send(msgOut);
                ////////////Lancement du thread lisant les données entrant////////////////////
                DataThread data = new DataThread(splitContainer1, serveur);
                threadMessageReceive.Start((object)data);
            }
            catch (System.Net.Sockets.SocketException)
            {
                Console.WriteLine("Erreur de connexion");
            }
            catch (System.ArgumentException)
            {
                Console.WriteLine("Erreur de connexion");
            }
            catch (System.InvalidOperationException)
            {
                Console.WriteLine("Erreur de connexion");
            }
 
        }
        /***********************************METHODE THREAD RECEIVER************************************/
 
 
        public static void receiveMessageTreat(object infos)
        {
            DataThread data = (DataThread)infos;
            SplitContainer split = data.sp;
            Socket server = data.sock;
 
 
            /********************************TRAITEMENT DU MESSAGE****************************/
            while (true)
            {
                //Reception des paquets!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
                try
                {
                    int n = serveur.Receive(msgIn);
                }
                catch (SocketException ev)
                {
                    break;
                }
                string s = ASCIIEncoding.Default.GetString(msgIn);
                if (s.Contains(Protocole.DEMAND_ACK))
                {
                    split.Visible = true;//Voici L'ERREUR en utilisant l'objet de L'UI
                }
 
 
                Thread.Sleep(10);
            }
 
        }

07/04/2011, 16h23
Nathanael Marchand

Code:

split.Invoke(()=>{split.Visible = true;});

J'ai copié le code mais ce donne des erreurs
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 /********************************TRAITEMENT DU MESSAGE****************************/ while (true) { //Reception des paquets!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! try { int n = serveur.Receive(msgIn); } catch (SocketException ev) { break; } string s = ASCIIEncoding.Default.GetString(msgIn); if (s.Contains(Protocole.DEMAND_ACK)) { split.Invoke(()=>{split.Visible = true;}); }
et voici l'erreur,

Citation:

Error 2 Invalid expression term ')' D:\Telecom Unit\Practice\Programming\C#\RemoteAcces_Project\ClientRemote\ClientRemote\Form1.cs 90 35 ClientRemote
Error 3 Invalid expression term '>' D:\Telecom Unit\Practice\Programming\C#\RemoteAcces_Project\ClientRemote\ClientRemote\Form1.cs 90 37 ClientRemote
Error 4 ) expected D:\Telecom Unit\Practice\Programming\C#\RemoteAcces_Project\ClientRemote\ClientRemote\Form1.cs 90 38 ClientRemote
Error 5 Invalid expression term ')' D:\Telecom Unit\Practice\Programming\C#\RemoteAcces_Project\ClientRemote\ClientRemote\Form1.cs 90 61 ClientRemote

07/04/2011, 18h01
Nathanael Marchand

Quelle version de .Net ?
08/04/2011, 13h03
fiberMan

Reponse au Discussion

D'aprés le MSDN 2005 et Visual Studio 2005, La version de Framework .NET utilisé est 2.0.
08/04/2011, 13h14
Nathanael Marchand

Ah c'est pour ca que y'a pas de lambda expressions.
Bon ben alors faut faire ca:

Code:

split.Invoke(delegate(){split.Visible = true;});

Reponse au Discussion

Il y en a toujours, (erreur)
Voici le code

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
 
/***********************************METHODE THREAD RECEIVER************************************/
 
 
        public static void receiveMessageTreat(object infos)
        {
            DataThread data = (DataThread)infos;
            SplitContainer split = data.sp;
            Socket server = data.sock;
 
 
            /********************************TRAITEMENT DU MESSAGE****************************/
            while (true)
            {
                //Reception des paquets!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
                try
                {
                    int n = serveur.Receive(msgIn);
                }
                catch (SocketException ev)
                {
                    break;
                }
                string s = ASCIIEncoding.Default.GetString(msgIn);
                if (s.Contains(Protocole.DEMAND_ACK))
                {
                    //ERREUR D'UTILISATION DES COMPOSANTS UI
                    split.Invoke(delegate() { split.Visible = true; });
                }

Et l'erreur :

Citation:

Error 1 The best overloaded method match for 'System.Windows.Forms.Control.Invoke(System.Delegate)' has some invalid arguments D:\Telecom Unit\Practice\Programming\C#\RemoteAcces_Project\ClientRemote\ClientRemote\Form1.cs 90 21 ClientRemote
Error 2 Argument '1': cannot convert from 'anonymous method' to 'System.Delegate' D:\Telecom Unit\Practice\Programming\C#\RemoteAcces_Project\ClientRemote\ClientRemote\Form1.cs 90 34 ClientRemote

08/04/2011, 14h02
Nathanael Marchand

Bigre je suis pas habitué a de si vieilles versions :D

Cette fois ci, c'est la bonne:

Code:

split.Invoke(new MethodInvoker(delegate { split.Visible = true; }));
08/04/2011, 14h07
NejNej

Sinon pourquoi ne pas simplement utiliser un backgroundworker?
08/04/2011, 14h35
fiberMan

Suite au Discussion
OK! Ça marche. Merci à vous. Mais j voudrai juste savoir la signification exacte de code
Code:

1 2 split.Invoke(new MethodInvoker(delegate { split.Visible = true; }));
Et encore merci pour le tuto backgroundworker

Voir 40 message(s) de cette discussion en une page