Discussion :

[calou_33]

Bonjour

Je n'arrive pas à utiliser la fonction WaitForMultipleObjects.

Dans ma fiche principale j'ai ceci :

Code :

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

1
2
3
4
5
6
7
8
9
10
 
    for ms := 1 to 12 do
    begin
      tab_thread[ms-1]:=TThreadGraphSynthese.Create(tab_ibc_qry[ms-1],nom_stored_proc,prjt,'T'+IntToStr(t),EncodeDate(an,ms,1),IncMonth(EncodeDate(an,ms,1),1));
      //recupere le handle
      tab_thread_hdl[ms-1]:=tab_thread[ms-1].Handle;
    end;
 
    //attend la fin des threads
    WaitForMultipleObjects(12,@tab_thread_hdl,TRUE,INFINITE);

Je créé les threads récupere le handle et attend la fin

Voici la fonction de création de mon thread

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
 
constructor TThreadGraphSynthese.Create(ibc_qry:TIBCQuery; 
nom_stored_proc,prjt,trbn: string; dt_deb,dt_fin:TDateTime);
begin
  //FreeOnTerminate:=TRUE;
  IbcQry:=ibc_qry;
  IbcQry.SQL.Text:='SELECT * FROM '+nom_stored_proc+'(:PRJT, :TRBN, 
:DATE_DEB, :DATE_FIN)';
  IbcQry.ParamByName('PRJT').AsString:=prjt;
  IbcQry.ParamByName('TRBN').AsString:=trbn;
  IbcQry.ParamByName('DATE_DEB').AsDate:=dt_deb;
  IbcQry.ParamByName('DATE_FIN').AsDate:=dt_fin;
  ThreadTerminated:=FALSE;
  OnTerminate:=OnTerminateProcedure;
  Inherited Create(FALSE);
end;
 
procedure TThreadGraphSynthese.OnTerminateProcedure(Sender: TObject);
begin
  ThreadTerminated:=TRUE;
end;
procedure TThreadGraphSynthese.Execute;
begin
  IbcQry.Execute;
end;

je remarque que lorsque la fonction WaitForMultipleObjects est terminée mes
threads ne le sont pas car si je regarde la variable ThreadTerminated elle
est à false. Et ensuite j'ai des violations d'acces sur des variables non
initialisées.

Merci

[Andnotor]

Commence déjà par mettre le inherited à la première ligne du constructor.

Code :

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

1
2
3
4
5
6
constructor TThreadGraphSynthese.Create(ibc_qry:TIBCQuery; 
nom_stored_proc,prjt,trbn: string; dt_deb,dt_fin:TDateTime);
begin
  Inherited Create(FALSE);
  ...
end;

[calou_33]

Bonjour,

C'est fait. Le comportement du waitformultipleobjects est le meme

Merci

[Andnotor]

Il n'y a rien d'autre qui me choque . WaitForMultipleObjects est correct !
Je viens encore de faire un essai et ça fonctionne...

[calou_33]

Ca fonctionne?

Et bien ca alors!! Je veux bien voir le code car il doit y avoir quelque chose de different. Moi quand Waitfor... est terminé mon boolean ThreadTerminated est à false

Amitiés

[Andnotor]

Je n'avais pas regardé ton code en entier...

OnTerminate devrait pointer sur une méthode du thread principal et non sur une du thread secondaire. (L'appel étant Synchronize)

Dans ton cas, il suffirait aussi simplement de mettre ThreadTerminated:=TRUE à la fin du Execute.

[Franck SORIANO]

Juste une remarque :
Est-ce que tu es sûr que le composant TIBCQuery soit thread-safe ? et surtout est-ce que tu utilises une connexion Db par query ou est-ce que tu as une seule connexion pour toutes les query ?

Je dis ça parce que je connais très peu d'API base de données qui acceptent d'exécuter des requêtes concurrantes avec la même connexion... et encore celles qui le font sérialisent les requêtes.

[calou_33]

Bonsoir,

Est-ce que tu es sûr que le composant TIBCQuery soit thread-safe ? et surtout est-ce que tu utilises une connexion Db par query ou est-ce que tu as une seule connexion pour toutes les query ?

J'ai fait le test en créant une variable locale dans le execute et en l'incrémentant. J'ai enlevé tout ce qui concerne les ibquery.
while cpt<200
inc(cpt)

Le probleme est le meme.

J'ai trouvé ceci : http://www.delphicorner.f9.co.uk/articles/op4.htm

The first thing you'll notice in the code is that I actually employ two types of threads. One, TMasterThr, is used to spawn the other two threads. That's pretty much all it does. Why did I do that? I wanted to include a WaitForMultipleObjects call in my code which would make the program wait for the copying threads to terminate before moving on. But the calling thread just doesn't wait; it sleeps, which means that it doesn't receive any messages while it's waiting. Therefore, if I put the WaitForMultipleObjects call in the main thread of the program, it would lock up and not receive messages. Not good.

Apparement on ne peut pas l'utiliser dans la fiche principale. Mais pour quelle raison? Je ne vois pas trop

Amitiés

[ShaiLeTroll]

au fait à quoi sert ThreadTerminated ? la propriété Terminated du TThread ne suffit pas ?

Sinon, WaitForMultipleObjects c'est un peu violent, pour le confort de l'utilisateur, tu pourrais faire une boucle et afficher une pseudo progression*, car là, tu auras droit à un écran gelé ...

A la fin du Execute, chaque thread va augmenter un compteur (géré avec section critique) et lorsqu'il arrive au nombre de thread, c'est que c'est terminé, en plus cela peut simuler cette pseudo progression et sans freeze !

Pour IBQuery, il est recommandé, d'instancier l'objet Connection et Query dans le Thread ... un ancien collègue avait eu des problèmes en utilisant des objets qui interagisse entre les threads ...

Sinon, ton SQL à quoi ressemble-t-il, par hazard, ça ne pourrait pas se lancer en une seule requête avec des Group by bien utilisé ?

[calou_33]

Bonjour,

au fait à quoi sert ThreadTerminated ? la propriété Terminated du TThread ne suffit pas ?

Sans doute. Je ne connaissais pas son existence

Sinon, WaitForMultipleObjects c'est un peu violent, pour le confort de l'utilisateur, tu pourrais faire une boucle et afficher une pseudo progression*, car là, tu auras droit à un écran gelé ...

Oui c'est ce que je fais déjà. Mais j'appelle application.processmessages pour rafraichir et ca me prend du cpu. Je voulais tester avec waitformul... qui parrait il est optimisée pour faire de l'attente

A la fin du Execute, chaque thread va augmenter un compteur (géré avec section critique) et lorsqu'il arrive au nombre de thread, c'est que c'est terminé, en plus cela peut simuler cette pseudo progression et sans freeze !

Je vais essayer ca

Pour IBQuery, il est recommandé, d'instancier l'objet Connection et Query dans le Thread ... un ancien collègue avait eu des problèmes en utilisant des objets qui interagisse entre les threads ...

Je créé une connexion un query par thread que je passe en argument par le create. Je peux les creer dans le thread mais j'en ai besoin apres que le thread soit terminé. Donc le thread ne doit pas les détruire. A voir...

Sinon, ton SQL à quoi ressemble-t-il, par hazard, ça ne pourrait pas se lancer en une seule requête avec des Group by bien utilisé ?

Euh je vais regarder car j'appelle pas mal de procédures

Merci

[mavrix91]

Bonjour,


Sans doute. Je ne connaissais pas son existence


Oui c'est ce que je fais déjà. Mais j'appelle application.processmessages pour rafraichir et ca me prend du cpu. Je voulais tester avec waitformul... qui parrait il est optimisée pour faire de l'attente


Je vais essayer ca


Je créé une connexion un query par thread que je passe en argument par le create. Je peux les creer dans le thread mais j'en ai besoin apres que le thread soit terminé. Donc le thread ne doit pas les détruire. A voir...


Euh je vais regarder car j'appelle pas mal de procédures

Merci

Bonjour,

Sans doute. Je ne connaissais pas son existence

Oui c'est ce que je fais déjà. Mais j'appelle application.processmessages pour rafraichir et ca me prend du cpu. Je voulais tester avec waitformul... qui parrait il est optimisée pour faire de l'attente

Merci

Application.processmessages peut aussi apporter des pb de réentrance. Si tu veux pas voir le petit voyant de ton gestionnaire des taches devenir tout vert tu peux rajouter un sleep(n) n tout petit, dans ta boucle de processmessages.

Sinon le blocage de waitforxxxxxobject dans le thread principal de ton application bloque tout mais tu peux tout à fait créer un thread dans lequel tu va lancer tes autres thread. Donc pas de freez.

Thread1
procedure Execute
Thread A
Thread B
Thread C
waitformultipleObject
.
.
.
.


L'interaction "inter-thread" d'un composant vcl doit être considéré avec soin.
J'espère que tes query ne sont pas liés a une grille ou autre composant DBmachin. Sinon ça peux être le souk.
Si tu as un composant commun entre tes query. Je n'ai jamais utilisé les IBCQUERY mais j'ai vu qu'il y avait un composant connexion et transaction. Il faut éviter d'utiliser le même pour tout tes query pour ne pas courir le risque de d'avoir des accès multiples asynchrones si tout ça n'est pas threadsafe.

As tu vraiment l'utilité d'avoir n thread pour n query et pas un thread qui exécuterais toutes tes query ?