Thread et datacontext

Version imprimable

21/10/2010, 15h28
azerto00

Thread et datacontext
Bonjour a tous, J'ai une question ...

J'ai un contexte de donne que je charge par
Code:

1 2 3 GestionDomainContext contexte = new GestionDomainContext(); contexte.Load(contexte.GetParaGestionQuery());
Est-il possible de faire un thread, de maniere a ce que mon code attende que l'entite soit chargee ?

Je sais que je peux faire
Code:

1 2 contexte.Load(contexte.GetParaGestionQuery()).Completed += (o, e) => ma_methode();
mais cela ne m'est pas utile car j'ai plusieurs entité a chargée, et je voudrais que lorsque toute mes entités dont j'ai besoin soit charge, le code suis son cours ..

Quelqu'un aurait-il une idée ?

Tu pourrais essayer un truc du genre (non testé):

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
 
public class Flagger
{
    public Dictionary<string,bool> flags;
 
   public event System.EventHandler FlaggerCompleted;
 
   // Ajoute un flag
 
   public void Add( string flagName )
   {
       this.flags.Add( flagName, false );
   }
 
   public void Clears()
   {
       this.flags.Clear();
   }
 
   public void Set( string flagName )
   {
         this.flags[ flagName ] = true;
 
         lock( this.flags )
         {          
         foreach( bool value in this.flags.Values )
         {
              if( value == false )
              {
                   return;
              }
         }
         }
 
         // tout le monde a terminé
 
         if( FlaggerCompleted != null )
         {
             this.FlaggerCompleted( this, null ); 
         }
   }
}

Pour l'appel :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
 
 
  Flagger flagger = null;
 
  public void Load()
 {
      this.flagger = new Flagger();
      // execution de la fin
      this.flagger.Completed += (s,e) => ma_methode_de_fin();
 
      flagger.Add("Table1");
      flagger.Add("Table2");
 
      // chargement de la table 1
      contexte.Load(contexte.GetParaGestion1Query()).Completed += (o, e) => flags.Set("Table1");
      // chargement de la table 2
      contexte.Load(contexte.GetParaGestion2Query()).Completed += (o, e) => flags.Set("Table2");
 }

Les méthodes abonnés aux completeds devraient être affectées à des delegates pour éviter les memoryleaks :)

21/10/2010, 21h26
jmix90

Hello,

Le reactive framework te permet de faire cela assez simplement...

Voici l'exemple qui te concerne où 3 Threads de calculs sont lancés parallèlement (tes appels Load) et un méthode est appelée à la fin du traitement des 3 threads : http://rxwiki.wikidot.com/101samples#toc3

Le site des Reactive extension est le suivant : http://msdn.microsoft.com/en-us/devlabs/ee794896.aspx

Bon courage...

La proposition de Samoteph me semble également très bien.

Simplement il faudrait peut-être changer le lock ainsi :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
lock( this.flags )
{       
    this.flags[ flagName ] = true;
 
    foreach( bool value in this.flags.Values )
    {
        if( value == false )
        {
            return;
        }
    }
}

22/10/2010, 09h18
Samuel Blanchard

oui effectivement :)

Bonjour a tous !
Excusez moi pour ce retard de réponse...
Alors j'ai teste la solution propose par Samoteph mais cela ne marche pas.
J'ai du faire quelques modifs, les voici :

Classe :

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
public class Flagger
    {
        public Dictionary<string, bool> flags;
        public event System.EventHandler FlaggerCompleted;
 
        // Ajoute un flag
 
        public void Add(string flagName)
        {
            this.flags.Add(flagName, false);
        }
 
        public void Clears()
        {
            this.flags.Clear();
        }
 
        public void Set(string flagName)
        {
            this.flags[flagName] = true;
 
            lock (this.flags)
            {
                this.flags[flagName] = true;
 
                foreach (bool value in this.flags.Values)
                {
                    if (value == false)
                    {
                        return;
                    }
                }
            }
 
            // tout le monde a terminé
 
            if (FlaggerCompleted != null)
            {
                this.FlaggerCompleted(this, null);
            }
        }
 
    }

Cote appel :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
Flagger flagger = null;
 
            flagger = new Flagger();
            // execution de la fin
            flagger.FlaggerCompleted += (s, e) => ActionForContextAppliGerstionCompleted();
 
            flagger.Add("Table1");
            flagger.Add("Table2");
 
            // chargement de la table 1
            contexte.Load(contexte.GetParaGestionQuery()).Completed += (o, e) => flagger.Set("Table1");
            // chargement de la table 2
            contexte.Load(contexte.GetParaGestionQuery()).Completed += (o, e) => flagger.Set("Table2");

26/10/2010, 12h10
Samuel Blanchard

Qu'est ce qui ne marche pas et quelles sont les modifications que tu as fait ?
27/10/2010, 17h25
azerto00

Les modifications sont telles qu'afficher sur ma reponse precedente..
L'erreur est une erreur silverlight, HandleExeption je crois. (Je reste vague sur l'erreur car j'ai modifier mon code depuis )

Ce que je cherche en faite, c'est pas vraiment d'exécuter une méthode a la fin de tout les chargement mais plutôt d'exécuter mes query en mode synchrone.
C'est a dire que je veux qu'une fois seulement que mes query sont faite (dans le constructeur), le reste du code s'exécute.

N'y a t-il pas un moyens simple pour faire cela ?
27/10/2010, 23h38
GuruuMeditation

Tu peux lancer tes querys dans un backgroundworker. Et dans le thread principal, attendre que celui-ci ait fini.
28/10/2010, 10h00
Samuel Blanchard

Citation:

Les modifications sont telles qu'afficher sur ma reponse precedente..

C'est à dire qu'on ne voit pas trop la différence du premier coup d'oeil entre les deux versions. Cela porte sur le XAML ou sur le .cs ?

Citation:

L'erreur est une erreur silverlight, HandleExeption je crois. (Je reste vague sur l'erreur car j'ai modifier mon code depuis )

Mais en restant vague on ne pourra pas trop t'aider.

Citation:

Ce que je cherche en faite, c'est pas vraiment d'exécuter une méthode a la fin de tout les chargement mais plutôt d'exécuter mes query en mode synchrone.

Ta requête est une demande classique en silverlight. Mais si tu restes dans une volonté de faire du synchrone à tout prix, en C# ou VB.Net, tu seras déçu, car ce modèle ne s'applique pas bien à Silverlight.
28/10/2010, 13h59
azerto00
Concernant les modifications, c'était juste un problème lors de nom de méthode a changer .(FlaggerCompleted au lieu de .Completed)

- Bon pour l'erreur, apparemment en mode débogage, cela viendrait de

Code:

flagger.Add("Table1");

J'ai tente de regarder en mode pas a pas, ou de rajouter en dure (dans le constructeur) un entite dans le dictionnaire en question.

Mais je comprend vraiment pas, tout est en public, et une fois sur la ligne, un appui sur F10, et j'arrive sur
Code:

1 2 3 4 5 private void ContentFrame_NavigationFailed(object sender, NavigationFailedEventArgs e) { e.Handled = true; ErrorWindow.CreateNew(e.Exception); }
Il y a donc un erreur, mais vraiment la, je reste incompréhensif.8O

--> Au niveau de l'asynchrome, c'est bien mais .... pour mon cas, il faudrais vraiment que les entites que j'ai besoin soient charge avant d'aller plus loin ...
Il y a pas la possibilité de charger toutes les entités d'une table ?

--> En C, avant de faire un un fork, il y a la possibilité d'appeler la fonction wait() qui attend qu'un processus fils (le fork) se finisse. Existe-il une fonction dans le même genre que wait en c# ?
28/10/2010, 15h19
GuruuMeditation

Citation:

Envoyé par azerto00

--> En C, avant de faire un un fork, il y a la possibilité d'appeler la fonction wait() qui attend qu'un processus fils (le fork) se finisse. Existe-il une fonction dans le même genre que wait en c# ?

Tu peux faire une boucle tant que Thread.IsAlive == true.

Tu n'as pas du chercher longtemps l'origine de l'erreur (nullreferenceexception) ;). Le problème vient du dictionnaire qui n'etait pas instancié.

Je te remets le code complet :

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
 
    public class Flagger
    {
        public Dictionary<string, bool> flags = new Dictionary<string,bool>();
        public event System.EventHandler Completed;
 
        // Ajoute un flag
 
        public void Add(string flagName)
        {
            this.flags.Add(flagName, false);
        }
 
        public void Clears()
        {
            this.flags.Clear();
        }
 
        public void Set(string flagName)
        {
            lock (this.flags)
            {
                this.flags[flagName] = true;
 
                foreach (bool value in this.flags.Values)
                {
                    if (value == false)
                    {
                        return;
                    }
                }
            }
 
            // tout le monde a terminé
 
            if (Completed != null)
            {
                this.Completed(this, null);
            }
        }
    }

Citation:

Au niveau de l'asynchrome, c'est bien mais .... pour mon cas, il faudrais vraiment que les entites que j'ai besoin soient charge avant d'aller plus loin ...
Il y a pas la possibilité de charger toutes les entités d'une table ?

La suite de ton code doit se situer dans l'evenement Completed comme suit (ou dans une autre méthode appelée dans Completed) :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
            Flagger flagger = new Flagger();
 
            // Execution de la fin
            flagger.Completed += (s, e) =>
            {
                MessageBox.Show("Toutes les tables ont été chargées !");
            };
 
            flagger.Add("Table1");
            flagger.Add("Table2");
 
      // chargement de la table 1
      contexte.Load(contexte.GetParaGestion1Query()).Completed += (o, e) => flags.Set("Table1");
      // chargement de la table 2
      contexte.Load(contexte.GetParaGestion2Query()).Completed += (o, e) => flags.Set("Table2");

Citation:

En C, avant de faire un un fork, il y a la possibilité d'appeler la fonction wait() qui attend qu'un processus fils (le fork) se finisse. Existe-il une fonction dans le même genre que wait en c#

Tu peux regarder du coté de la classe Thread. Comme le note azerto00 tu peux faire une boucle en utilisant la methode IsAlive mais ton interface graphique sera freezée et je ne pense pas que les performances de ce genre de boucle soit excellente.

Bon courage pour la suite :)

02/11/2010, 16h57
stailer
Samoteph, je viens de trouver ce post par hasard et j'ai mis en place ta classe : ça fonctionne impec... pas mal la petite subtilité avec "lock", je connaissais pas.

Juste un truc dans l'exemple que tu donnes dans le dernier bout de code :
Code:

1 2 contexte.Load(contexte.GetParaGestion1Query()).Completed += (o, e) => flags.Set("Table1");
Je pense que c'est à remplacer par :
Code:

1 2 contexte.Load(contexte.GetParaGestion1Query()).Completed += (o, e) => flagger.Set("Table1");
Ou alors j'ai raté quelque chose ;)

En fait dans mon cas je lance des méthodes sur chaque ajout au Flag.. je me suis donc permis de modifier ta classe :

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
 
public class Flagger
    {
        public Dictionary<string, bool> flags = new Dictionary<string, bool>();
        private List<Action> actions = new List<Action>();
 
        public event System.EventHandler Completed;
 
 
        public void Add(Action ExecuteAfter)
        {
            this.flags.Add(ExecuteAfter.Method.Name, false);
            actions.Add(ExecuteAfter);
        }
 
 
        public void Run()
        {
            foreach (Action c in actions)
            {
                c.Invoke();
            }
        }
 
 
        public void Clears()
        {
            this.flags.Clear();
        }
 
        public void Set(string flagName)
        {
            lock (this.flags)
            {
                this.flags[flagName] = true;
 
                foreach (bool value in this.flags.Values)
                {
                    if (value == false)
                    {
                        return;
                    }
                }
            }
 
            // tout le monde a terminé
            if (Completed != null)
            {
                this.Completed(this, null);
            }
        }
 
 
    } // fin classe

Comme ça je peux faire directement :

Code:

1
2
3
 
  batch.Add(ChargerListes);
  batch.Add...

Je peux en faire plusieurs et quand je suis prêt à lancer mes actions, je fais :

Code:

1
2
 
batch.Run()

La méthode appelée dans l'exemple :

Code:

1
2
3
4
5
6
7
8
9
10
11
 
public void ChargerListes()
        {
            bddContext.Load<SimpleClient>(bddContext.getClientsQuery(), LoadBehavior.MergeIntoCurrent,
            loB =>
            {
                  this.ListClients = new ObservableCollection<SimpleClient>(loB.Entities);
 
            }, true).Completed += (o, e) => this.batch.Set("ChargerListes");
 
        }

02/11/2010, 19h41
Samuel Blanchard

Pour le nom flags vers flagger, j'ai changé de nom en cours de route et oublié de remplacer cette occurence :aie:

Sinon j'aime bien la modification que tu as apporté à la classe :)
Je pense écrire un papier sur mon blog sur cette classe de synchro car c'est une demande assez récurrente. Si tu me le permets je rajouterai ta contribution (en te nommant bien sur :) )
03/11/2010, 09h28
stailer

No problem... T'es pas obligé puisque tu as fait 99.9% du boulot ;)

J'ai rajouté une autre méthode dans ta classe Flagger :

Code:

1
2
3
4
5
6
7
8
9
10
 
        public void FlagComplete()
        {
            StackTrace stackTrace = new StackTrace();
            StackFrame stackFrame = stackTrace.GetFrame(1);
 
            string[] a = stackFrame.GetMethod().Name.Split('>');
            if (a.Length > 0 && a[0].Length > 1) 
                this.Set(a[0].Substring(1, a[0].Length - 1));
        }

Au lieu d'avoir :

Code:

1
2
3
4
5
6
7
8
9
10
public void ChargerSuperviseurs()
        {
            bddContext.Load<BDC_UTILISATEURSBC>(bddContext.getUtilisateursBCSuperviseurQuery(), LoadBehavior.MergeIntoCurrent,
            loB =>
            {
                this.ListeSuperviseurs = new ObservableCollection<BDC_UTILISATEURSBC>(loB.Entities);
                this.batch.Set("ChargerSuperviseurs");
            }, true);
        }

Je peux remplacer la ligne en gras ci dessus par :

Code:

1
2
 
this.batch.FlagComplete();

Ca m'inquiétait un peu de devoir recopier mes noms de méthodes... J'ai donc rajouté ça FlagComplete sur Flagger pour qu'il s'occupe de le retrouver à ma place.

04/11/2010, 15h29
azerto00

Bon, j'ai eu du retard dans ma réponse, mais cela marche très bien !

Et c'était un erreur toute bête d'initialisation du dictionnaire ...
En tout cas merci a tous !
Bonne journée !
05/11/2010, 23h58
Samuel Blanchard

Citation:

Ca m'inquiétait un peu de devoir recopier mes noms de méthodes... J'ai donc rajouté ça FlagComplete sur Flagger pour qu'il s'occupe de le retrouver à ma place.

J'avais un peu la même inquiétude que toi mais j'ai pris une voie un peu différente.

Je te laisse le soin de le découvrir.

http://blog.naviso.fr/wordpress/?p=264