Probleme de ThreadPool

Version imprimable

Bonjour

J'essaye de lancer un process un peu lourd dans un nouveau thread

Le premier probleme auquel je me heurte c'est la définition des parametres

Si j'ai bien lu la doc il existe deux mode d'appel : avec ou sans parametres
Code:

1 2 QueueUserWorkItem(WaitCallback) // Queues a method for execution. The method executes when a thread pool thread becomes available. QueueUserWorkItem(WaitCallback, Object) // Queues a method for execution, and specifies an object containing data to be used by the method. The method executes when a thread pool thread becomes available.
Mais si j'essaye sans et donc sans donner de parametre a ma methode appelée je recois un message d'erreur

Donc actuellement je fais ceci :
Mais je ne comprends pas comment donner une valeur a 'rien' qui vient de nulle part ?
Code:

1 2 3 4 5 6 7 8 private void btnMatrix_Click(object sender, EventArgs e) { ThreadPool.QueueUserWorkItem(new WaitCallback(Process)); } void Process(Object rien) { }

07/10/2008, 22h28
StormimOn

Le délégué WaitCallback doit être utilisé avec des méthodes prenant un objet en paramètre et ne renvoyant rien. Même si ta méthode n'a pas besoin de paramètre, tu dois tout de même en mettre un (raison de ton message d'erreur au début donc).

Ensuite soit tu n'as pas besoin de ce paramètre et tu passes par

Code:

ThreadPool.QueueUserWorkItem(new WaitCallback(Process));

La valeur du paramètre sera alors null.

Soit tu souhaites utiliser le paramètre et alors

Code:

ThreadPool.QueueUserWorkItem(new WaitCallback(Process), valeurDuParametre);
07/10/2008, 22h58
olibara

Merci StormimOn

J'avais fini par digerer le truc (+/-)

J'ai réussi a faire mon delegate et mon call back
Mais c'est le genre de truc a faire tout les jours pour s'habituer !

Car il y a quand meme de quoi se faire un noeud dans les neurones si on n'a pas pris le pli !

En l'occurence je calcule une matrice asser lourde dont je place le resultat en datatable.
Pour distraire l'utilisateur, J'update un label a chaque cellule et je met a jour un dgv a chaque row
Je fais le calcul de la matrice dans un Thread et j'invoke deux delegués pour mes mise a jour !

pfff : j'ai pris deux nurofen !

Salut Stormimon

J'ai une derniere misere que tu va peut-etre m'aider a comprendre
Je met la source ici pour l'explication

Je lance le Thread
J'intercepte deux event
AddCell et AddRow
A chaque AddRow je met un DGV a jour dans ma form
Quand le thread se termine, j'appelle une derniere mise a jour (this.AddRow)

Mais la j'ai une erreur de conlit de thread ?
Que dois-je faire pour bien faire ?

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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
using System;
using System.Data;
using System.Drawing;
using System.IO;
using System.Windows.Forms;
using DGVPrinterHelper;
using System.Threading;
 
 
 
namespace MapScopeNG
{
  public partial class frmDist : Form
  {
    DataTable dtAdr = null;
    public frmDist(DataTable dt)
    {
      dtAdr = dt;
      InitializeComponent();
    }
 
    public void ShowMatrix()
    {
      this.Show();
      DistMatrix dm = new DistMatrix();
      dm.AddRow += new DistMatrix.StepRowDelegateHandler(Dist_StepRow);
      dm.AddCell += new DistMatrix.StepCellDelegateHandler(Dist_StepCell);
 
      ThreadPool.QueueUserWorkItem(new WaitCallback(Process),dm);
      int a = 8;
    }
 
    void Process(Object rien)
    {
      DistMatrix dm = (DistMatrix)rien;
      DataTable dtn = dm.getMatrix(dtAdr);
      AddRow(dtn);
      btn_print.Visible = true;
    }
    bool Started = false;
 
 
 
    // *****************************************************************************************
    public delegate void StepCellDelegateHandler(int a, int b);
 
    private void Dist_StepCell(int a, int b)
    {
      if (this.InvokeRequired)
      {
        try
        {
          this.Invoke(new StepCellDelegateHandler(StepCell), new object[] { a, b });
          return;
        }
        catch (Exception)
        {
        }
      }
      this.StepCell(a, b);
    }
    // *****************************************************************************************
 
    private void StepCell(int X,int Y)
    {
      lbl_Progress.Text = string.Format("{0}-{1} / {2}", Y, X,dtAdr.Rows.Count);
    }
 
    // *****************************************************************************************
    public delegate void StepRowDelegateHandler(DataTable dt);
 
    private void Dist_StepRow(DataTable dt)
    {
      if (this.InvokeRequired)
      {
        try
        {
          this.Invoke(new StepRowDelegateHandler(AddRow), new object[] { dt });
          return;
        }
        catch (Exception)
        {
        }
      }
      this.AddRow(dt);
    }
 
    // *****************************************************************************************
    private void AddRow(DataTable Dt)
    {
      dgv_Dist.DataSource = null;
      dgv_Dist.DataSource = Dt;
      foreach (DataGridViewColumn dgvc in dgv_Dist.Columns)
      {
        DataGridViewCellStyle style = new DataGridViewCellStyle();
        style.Format = "N2";
        style.Alignment = DataGridViewContentAlignment.MiddleRight;
        dgvc.DefaultCellStyle = style;
      }
      dgv_Dist.Refresh();
    }
  }
}

Tu as juste oublié de mettre un bloc else pour le code à exécuter si InvokeRequired est à true. Résultat, tu exécutes toujours le code même lorsqu'il ne faut pas ;)

La bonne pratique c'est de rappeler la méthode en cours si InvokeRequired est à true et dans le else mettre le code que doit réaliser la méthode. La méthode est ainsi "illegal-cross-thread-call-safe" si l'on peut dire :aie:
Code:

1 2 3 4 5 6 7 8 9 10 11 private void MaMethode(...) { if (this.InvokeRequired) { // On exécute MaMethode sur le thread UI avec la méthode Invoke } else { // Code à exécuter } }

Salut StormimOn

Il y a sans doute encore qq chose qui m'échappe
J'ai adapté suivant ton conseil mais ca ne change rien au probleme

Pour info :

1- Le code marchait bien sans cette modif mais mon probleme etait la suite de l'execution APRES le process

2- La modif que j'ai faite ne change rien a l'execution mais ca plante toujours au meme endroit lorrsque l'on execute btn_print.Visible = true;

Je comprends pourquoi : on est toujours dans le second Thread

Ma question maintenant c'est COMMENT signaler la fin de l'execution du thread pour continuer le process normal

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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
using System;
using System.Data;
using System.Drawing;
using System.IO;
using System.Windows.Forms;
using DGVPrinterHelper;
using System.Threading;
 
 
 
namespace MapScopeNG
{
  public partial class frmDist : Form
  {
    DataTable dtAdr = null;
    bool Started = false;
    public frmDist(DataTable dt)
    {
      dtAdr = dt;
      InitializeComponent();
    }
 
    public void ShowMatrix()
    {
      this.Show();
      DistMatrix dm = new DistMatrix();
      dm.AddRow += new DistMatrix.StepRowDelegateHandler(Dist_StepRow);
      dm.AddCell += new DistMatrix.StepCellDelegateHandler(Dist_StepCell);
 
      ThreadPool.QueueUserWorkItem(new WaitCallback(Process),dm);
    }
 
    void Process(Object rien)
    {
      DistMatrix dm = (DistMatrix)rien;
      DataTable dtn = dm.getMatrix(dtAdr);
      btn_print.Visible = true;
    }
 
    // *****************************************************************************************
    public delegate void StepCellDelegateHandler(int a, int b);
 
    private void Dist_StepCell(int a, int b)
    {
      if (this.InvokeRequired)
      {
        try
        {
          this.Invoke(new StepCellDelegateHandler(StepCell), new object[] { a, b });
          return;
        }
        catch (Exception)
        {
        }
      }
      else
      {
        this.StepCell(a, b);
      }
    }
    // *****************************************************************************************
 
    private void StepCell(int X,int Y)
    {
      lbl_Progress.Text = string.Format("{0}-{1} / {2}", Y, X,dtAdr.Rows.Count);
    }
 
    // *****************************************************************************************
    public delegate void StepRowDelegateHandler(DataTable dt);
 
    private void Dist_StepRow(DataTable dt)
    {
      if (this.InvokeRequired)
      {
        try
        {
          this.Invoke(new StepRowDelegateHandler(AddRow), new object[] { dt });
          return;
        }
        catch (Exception)
        {
        }
      }
      else
      {
        this.AddRow(dt);
      }
    }
 
    // *****************************************************************************************
    private void AddRow(DataTable Dt)
    {
      if (dgv_Dist.DataSource == null)
      {
        dgv_Dist.DataSource = Dt;
        foreach (DataGridViewColumn dgvc in dgv_Dist.Columns)
        {
          DataGridViewCellStyle style = new DataGridViewCellStyle();
          style.Format = "N2";
          style.Alignment = DataGridViewContentAlignment.MiddleRight;
          dgvc.DefaultCellStyle = style;
        }
      }
      dgv_Dist.Refresh();
    }
  }
}

08/10/2008, 08h04
olibara

Truquage

Bonjour

Actuellement pour contourner les difficultés j'ai truqué

1- Ne trouvant pas comment je devais detecter que mon thead secondaire etait fini, j'ai pensé ajouter un troisieme event. Mais pour faire plus simple, j'ai truqué les parametre d'un delegate existant pour lui donner des valeurs "magiques" a la fin de l'execution.
Je ne sais pas s'il y a une methode plus "orthodoxe"

2- Est il possible de recuperer une valeur de retour d'un fonction appellée dans un thread ?
Dans le cas actuel j'appelle getmatrix qui me rends une datatable mais comme ca se passe dans le thread secondaire, cette datatable est inaccessible.
La aussi j'ai truqué pour la passer en parametre d'un delegate a la fin du process

J'ai donc paré a l'urgent mais j'ai le sentiment qu'on devrait pouvoir mieux faire ?
:aie:
:koi:
10/10/2008, 08h50
olibara

Salut StormimOn

Ce truc tourne toujours avec une bequille je pense

Tu n'a pas une petite suggestion ou recomandation pour intercepter proprement la fin du process ?

Merci beaucoup
10/10/2008, 13h26
StormimOn

Un événement est ce qu'il y a de plus logique à utiliser pour signaler la fin du thread, lorsqu'il est géré par un composant tiers, comme pour le BackgroundWorker avec l'événement RunWorkerCompleted.

Tu n'es pas dans ce cas de figure puisque tout le code est dans une Form, tu peux donc simplement appeler une méthode à la fin du thread qui se charge de finaliser l'opération (avec Invoke sur la partie graphique).

Arrivé à cette constatation, je pense qu'utiliser le ThreadPool n'est peut être pas l'idéal dans ton cas. Réaliser un appel de méthode asynchrone semble plus pratique. L'appel asynchrone d'une méthode permet d'appeler une méthode sur un autre thread (le framework s'en charge) et d'appeler automatiquement une autre méthode lorsque la première est terminée (lorsque le thread est terminé donc).

Avantage, les méthodes appelées ainsi peuvent renvoyer une valeur et la méthode de finalisation (AsyncCallback) s'exécute sur le thread utilisé pour l'appel de la première méthode il me semble (pas besoin de faire de InvokeRequired à ce moment si le thread d'appel est celui de l'UI).

Tu trouveras de quoi te documenter la dessus un peu partout ^^