Discussion :

[Blunt]

Bonjour,

Je souhaite passer dans le ThreadPool un bloc de code lourd à exécuter cependant le code ci dessous ne renvoi rien, c'est comme ci il rentre même dans la méthode TEST, merci de votre retour sur mon grand problème.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 void TEST()
        { 
            Object oMissing = System.Reflection.Missing.Value;
            Object oTrue = true;
            Object oFalse = false;
            Microsoft.Office.Interop.Word.Application oWord = new Microsoft.Office.Interop.Word.Application();
            Microsoft.Office.Interop.Word.Document oWordDoc = new Microsoft.Office.Interop.Word.Document();
            oWord.Visible = true;
            oWord.Visible = false;
            Object oTemplatePath = @".\1.doc";
            oWordDoc = oWord.Documents.Add(ref oTemplatePath, ref oMissing, ref oMissing, ref oMissing);         
 
            foreach (Microsoft.Office.Interop.Word.Range range in oWordDoc.Words)
            {
                if (range.Text.Trim().Contains("P"))
                {
                    int pos = range.Text.Trim().IndexOf("P");
                    string str = range.Text.Trim().Replace("P", "");
                    range.Text = str;
                }
 
            }
            Object oSaveAsFile = "./2.doc";
            oWordDoc.SaveAs(ref oSaveAsFile, ref oMissing, ref oMissing, ref oMissing,
            ref oMissing, ref oMissing, ref oMissing, ref oMissing, ref oMissing,
            ref oMissing, ref oMissing, ref oMissing, ref oMissing, ref oMissing,
            ref oMissing, ref oMissing);
 
            oWordDoc.Close(ref oFalse, ref  oMissing, ref oMissing);
            oWord.Quit(ref oMissing, ref oMissing, ref oMissing);
        }
 
        static void Main(string[] args)
        {
 
 
                Program test = new Program();
                ThreadPool.QueueUserWorkItem(o => test.TEST());
        }

[Bluedeep]

Tu as vérifié que tu rentrais bien dans la boucle foreach ?

Pourquoi ne met tu pas une méthode de callback, ainsi tu verrais si elle est appelé ?

[Blunt]

Tu as vérifié que tu rentrais bien dans la boucle foreach ?

Pourquoi ne met tu pas une méthode de callback, ainsi tu verrais si elle est appelé ?

Comment mettre la méthode de callback ? je pense que la méthode TEST n'est pas appelée.
Merci encore une fois.

[Bluedeep]

Comment mettre la méthode de callback ? je pense que la méthode TEST n'est pas appelée.

Pour le callback, laisse tomber.

Sinon, si tu met un BP dans ta méthode, est ce que tu break dessus ?

Sinon, si tu n'appelles pas ta méthode dans plusieurs threads, pourquoi utilises tu le threadPool plutot qu'un thread secondaire "classique".

[Blunt]

Pour le callback, laisse tomber.

Sinon, si tu met un BP dans ta méthode, est ce que tu break dessus ?

j'ai mis un writeline dans la méthode TEST, le message n'est pas affiché, donc il entre pas dans ma méthode.

[Blunt]

lors de l'ajout de Thread.Sleep(10000); , je rentre bien dans la méthode TEST, donc c'est un problème de temps. comment peut attendre juste la fin d'exécution de la méthode test ? Merci infiniment.

[Blunt]

Mon besoin est d'exécuter la méthode TEST en parallèle (faire 5 génération de fichiers word au mémé temps), merci de votre réponse.

[hegros]

Il faut faire un Join sur le Thread qui est lancé car juste après avoir ajouté un item dans la queue tu quittes le fonction main donc le processus se termine (mort du thread primaire)et tous les threads sont terminés. C'est pour cela qu'en ajoutant un Sleep juste après l'ajout d'un item dans une queue cela travaille un peu.

Tu peux utiliser les event http://msdn.microsoft.com/en-us/library/95hbf2ta.aspx

[Blunt]

J'ai essayé ce code :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
Object oMissing = System.Reflection.Missing.Value;
            Object oTrue = true;
            Object oFalse = false;
            Microsoft.Office.Interop.Word.Application oWord = new Microsoft.Office.Interop.Word.Application();
            Microsoft.Office.Interop.Word.Document oWordDoc = new Microsoft.Office.Interop.Word.Document();
            oWord.Visible = true;
            oWord.Visible = false;
            Object oTemplatePath = @".\1.doc";
            oWordDoc = oWord.Documents.Add(ref oTemplatePath, ref oMissing, ref oMissing, ref oMissing);         
 
            foreach (Microsoft.Office.Interop.Word.Range range in oWordDoc.Words)
            {
                if (range.Text.Trim().Contains("P"))
                {
                    int pos = range.Text.Trim().IndexOf("P");
                    string str = range.Text.Trim().Replace("P", "");
                    range.Text = str;
                }
 
            }
            Directory.CreateDirectory(@"F:\PS-IN\"+threadContext);
            Object oSaveAsFile = @"F:\PS-IN\" + threadContext+"\\" + threadContext + ".doc";
            oWordDoc.SaveAs(ref oSaveAsFile, ref oMissing, ref oMissing, ref oMissing,
            ref oMissing, ref oMissing, ref oMissing, ref oMissing, ref oMissing,
            ref oMissing, ref oMissing, ref oMissing, ref oMissing, ref oMissing,
            ref oMissing, ref oMissing);
            Console.WriteLine(threadContext+" "+DateTime.Now.ToShortTimeString());
            oWordDoc.Close(ref oFalse, ref  oMissing, ref oMissing);
            oWord.Quit(ref oMissing, ref oMissing, ref oMissing);
        }
 
        static void Main(string[] args)
        {
 
            const int FibonacciCalculations = 50;
 
            // One event is used for each Fibonacci object.
            ManualResetEvent[] doneEvents = new ManualResetEvent[FibonacciCalculations];
            Program[] fibArray = new Program[FibonacciCalculations];
            Random r = new Random();
 
            // Configure and start threads using ThreadPool.
            Console.WriteLine("launching {0} tasks...", FibonacciCalculations);
            for (int i = 0; i < FibonacciCalculations; i++)
            {
                doneEvents[i] = new ManualResetEvent(false);
                Program f = new Program();
                fibArray[i] = f;
                ThreadPool.QueueUserWorkItem(f.TEST,i);
            }
 
            // Wait for all threads in pool to calculate.
            WaitHandle.WaitAll(doneEvents);
            Console.WriteLine("All calculations are complete.");
 
}

il y a bien la génération des 50 fichiers word, par contre il sort jamais du wait, merci de votre aide.

[Nathanael Marchand]

C'est normal, tu ne fais jamais de doneEvents[i].Set(); pour signaler

[Blunt]

C'est normal, tu ne fais jamais de doneEvents[i].Set(); pour signaler

Effectivement et cela fonctionne! merci beaucoup, cependant j'ai une dernière question comment peut on passer à la méthode TEST des paramètres comme (string, arraylist,....), car je remarque que la tâche test ne prend en parametre que object . merci d'avance de votre retour.

[hegros]

Comme cela par exemple :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
class Program
{
 
 
   public void test(Parametre t)
   { 
      //code
 
   }
 
   public class Parametre
   {
      public int T
      {
          get;
	  set;
      }
 
   }
 
   public static void Main(string[] args)
   {
 
      Program p =new Program();
      Action<Parametre> fct = p.test;
 
      for(int i=0 ; i<10;i++)
      {
 
	  Parametre pa = new Program.Parametre();
	  pa.T = i;
 
          ThreadPool.QueueUserWorkItem(state=> fct(pa));
       }
   }
 
}

[Blunt]

Je n'ai pas pu faire passer un string, j'ai essayé :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
 
 
string str="test";
  for(int i=0 ; i<10;i++)
  {
 
	             Parametre pa = new Program.Parametre();
	             pa.T = i;	
                     ThreadPool.QueueUserWorkItem(state=> fct(str));
   }

j'ai une erreur de cast de type parametre to string, merci d'avance.

[hegros]

Oui mais non je te donnais un exemple avec une classe qui encapsule tes paramètres. Si tu n'as besoin que d'une string alors il faut changer 2 choses

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
Action<Parametre> fct = p.test;
 
par
 
Action<string> fct = p.test;

et biensûr

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
public void test(Parametre t)
   { 
      //code
 
   }
 
par
 
public void test(string t)
   { 
      //code
 
   }

Ensuite tu pourras faire

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
 
string str ="test";
ThreadPool.QueueUserWorkItem(state=> fct(str));

Tu comprends la code, ce qu'est une action et comment elle est utilisée avec QueueUserWorkItem ?

[Blunt]

Merci beaucoup, je ne gagne pas beaucoup avec le multi tâche est ce que c'est normal?.
D'après mes estimations, la génération de 4500 fichiers word avec une seule tâche prend un peu plus de 2heures et avec 4 tâches parallèles -> 1h40. j'opte pour faire cette génération dans 15min max, c'est possible ? merci d'avance.

[hegros]

oui il y a des limites, avoir plus de thread n'y changera pas grand chose pour des opérations d'entrée sortie(tu peux toujours essayer de créer un thread par fichier), si tu es avec le framewok 4 essaie plutôt les task (tpl) sinon utilise des thread lourd (processus). Ce qui consomme du temps c'est à priori ta boucle (ne faudrait-il pas utilisé UsedRange ?) avec un foreachParallel cela pourrait peut être s'améliorer (à tester)

[Nathanael Marchand]

Aaaah... Le parallèlisme!
Malheureusement, ce n'est pas en mettant neuf femmes enceintes qu'on obtient un bébé en 1mois!
Y'a surement des goulots d'étranglement qui font que malgré la concurrence, il y'a une sérialisation (et donc que tous les threads sont à la file).

[Blunt]

Aaaah... Le parallèlisme!
Malheureusement, ce n'est pas en mettant neuf femmes enceintes qu'on obtient un bébé en 1mois!
Y'a surement des goulots d'étranglement qui font que malgré la concurrence, il y'a une sérialisation (et donc que tous les threads sont à la file).

D'accord, a ton avis les goulots d'étranglement sont située ou ? dans word lui même? j'ai remarqué dans le gestionnaire de tâches windows pleins de processus winword.exe, est ce que c'est la cause de ce ralentissement ? Merci d'avance.

[Nathanael Marchand]

D'accord, a ton avis les goulots d'étranglement sont située ou ? dans word lui même? j'ai remarqué dans le gestionnaire de tâches windows pleins de processus winword.exe, est ce que c'est la cause de ce ralentissement ? Merci d'avance.

Alors là... Aucune idée! C'est assez complexe à diagnostiquer ca peut dépendre de tellement de paramètres (autant matériels que logiciels)...

[Blunt]

Alors là... Aucune idée! C'est assez complexe à diagnostiquer ca peut dépendre de tellement de paramètres (autant matériels que logiciels)...

j'ai fais comme suite :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
            int div = FUSIONSS.Count / 4;
            int it = 0;
            foreach (string ste in FUSIONSS)
            {
                it++;
                if (it <= div)
                Program.FUSIONSS_1.Add(ste);
                else if (it <= (2*div))
                Program.FUSIONSS_2.Add(ste);
                else if (it <= (3 * div))
                Program.FUSIONSS_3.Add(ste);
                else 
                Program.FUSIONSS_4.Add(ste);
            }
 
 
            Program.modelee = MODEL[0].ToString();
            const int FibonacciCalculations = 4;
 
            Program[] fibArray = new Program[FibonacciCalculations];
            Random r = new Random();
 
            Console.WriteLine("launching {0} tasks...", FibonacciCalculations);
 
            doneEvents[0] = new ManualResetEvent(false);
            Program f1 = new Program();
            fibArray[0] = f1;
            ThreadPool.QueueUserWorkItem(f1.FUSION, 0);
 
            doneEvents[1] = new ManualResetEvent(false);
            Program f2 = new Program();
            fibArray[1] = f2;
            ThreadPool.QueueUserWorkItem(f2.FUSION2, 1);
 
            doneEvents[2] = new ManualResetEvent(false);
            Program f3 = new Program();
            fibArray[1] = f3;
            ThreadPool.QueueUserWorkItem(f3.FUSION3, 2);
 
            doneEvents[3] = new ManualResetEvent(false);
            Program f4 = new Program();
            fibArray[1] = f4;
            ThreadPool.QueueUserWorkItem(f4.FUSION4, 3);
 
            WaitHandle.WaitAll(doneEvents);
            Console.WriteLine("All calculations are complete.");

et la méthode de fusion :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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
 
  public void FUSION(Object threadContext)
   {   
            foreach (string s in FUSIONSS_1)
            {   
 
 
                String[] tbStr2 = s.Split(new Char[] { ';' });
                string nb = tbStr2[0];
                Object oMissing = System.Reflection.Missing.Value;
                Object oTrue = true;
                Object oFalse = false;
                Microsoft.Office.Interop.Word.Application oWord = new Microsoft.Office.Interop.Word.Application();
                Microsoft.Office.Interop.Word.Document oWordDoc = new Microsoft.Office.Interop.Word.Document();
                oWord.Visible = true;
                oWord.Visible = false;
                Object oTemplatePath = modelee;
                oWordDoc = oWord.Documents.Add(ref oTemplatePath, ref oMissing, ref oMissing, ref oMissing);
                bool sympb = false; bool E = false; bool n = false; bool p = false; bool r = false;
 
                foreach (Microsoft.Office.Interop.Word.Range range in oWordDoc.Words)
                {if (range.Text.Trim().Contains("P"))
                    {   int pos = range.Text.Trim().IndexOf("P");
                        string str = range.Text.Trim().Replace("P", "O");
                        range.Text = str;} }
                Directory.CreateDirectory((Object)path + "./PUBLI/" + nb);
                Object oSaveAsFile = (Object)path + "./PUBLI/" + nb + "/" + nb + ".doc";
                oWordDoc.SaveAs(ref oSaveAsFile, ref oMissing, ref oMissing, ref oMissing,
                ref oMissing, ref oMissing, ref oMissing, ref oMissing, ref oMissing,
                ref oMissing, ref oMissing, ref oMissing, ref oMissing, ref oMissing,
                ref oMissing, ref oMissing);
                oWordDoc.Close(ref oFalse, ref  oMissing, ref oMissing);
                oWord.Quit(ref oMissing, ref oMissing, ref oMissing);
            }
            Initial.doneEvents[int.Parse(threadContext.ToString())].Set();
        }

j'ai créé 3 autres méthodes en dupliquant la tache fusion, elles correspondent au 4 taches parallèles.
Merci de vos remarques.