[C++] Classe Thread (ca marche)

Classe Thread (ca marche) [C++] - C++ - Programmation

Marsh Posté le 28-01-2004 à 23:21:15    

-edit-
RESOLU
Je réinvente la roue ! Je code une classe C++ qui encapsule les threads POSIX. Ca fonctionne bien sous Win32(MinGW) mais ca plante complètement sous Linux(g++).
RESOLU
-edit-
 
-edit-
Ne pas oublier de liker explicitement avec pthread.
-edit-
 
Voici le code:
 

Code :
  1. // Librairies C++ & STL
  2. #include<string>
  3. #include<iostream>
  5. // Librairies supplémentaires spéicifques Win32 ou GNU/Linux
  6. #ifdef WIN32
  7. #include<windows.h>
  8. #include<winbase.h>
  9. #include<process.h>
  10. #else
  11. #include<unistd.h>
  12.     #include<pthread.h>
  13. #endif
  15. // "Emulation" de quelques fonctions POSIX pour Win32
  16. #ifdef WIN32
  17. #define THREAD_FUNCTION void
  18. #define pthread_t HANDLE
  19. #define pthread_create(thhandle,attr,thfunc,tharg) ((*thhandle=(HANDLE)_beginthread(thfunc,0,tharg))==NULL)
  20. #define pthread_join(thread) ((WaitForSingleObject((thread),INFINITE)!=WAIT_OBJECT_0) || !CloseHandle(thread))
  21. #define pthread_detach(thread) if(thread!=NULL)CloseHandle(thread)
  22. #define pthread_exit(retval) _endthread();
  23. #define pthread_mutex_t HANDLE
  24. #define pthread_mutex_init(object,attr) *object=CreateMutex(NULL,false,NULL)
  25. #define pthread_mutex_destroy(object) CloseHandle(*object)#define pthread_mutex_lock(object) WaitForSingleObject(*object,INFINITE)
  26. #define pthread_mutex_unlock(object) ReleaseMutex(*object)
  27. #define sleep(nb) Sleep(nb000)
  28. #else
  29. #define THREAD_FUNCTION void *
  30. #endif
  32. // Classe de base : x_Filament exécute la fonction membre ::Traitement() de la classe dérivée. L'exécution de ::Traitement() met en oeuvre un filament (ou encore un 'thread' en anglais).
  33. class x_Filament
  34. {
  35. public:
  37. // Demarrer() crée un filament qui execute le traitement avec passage de l'argument
  38. int Demarrer( void * );
  40. // L'argument du filament
  41. void * Argument_Filament;
  43. // Le code du filament à surcharger par la classe dérivée
  44. virtual void Traitement( void * ) = 0;
  46. private:
  48. // L'identifiant du filament
  49. pthread_t Identifiant_Filament;
  50. };
  52. // Le 'Thread' qui execute le traitement avec passage de l'argument
  53. static THREAD_FUNCTION Filament( void * pthis ) {
  54. x_Filament * pParent = (x_Filament*)pthis;
  55. pParent->Traitement( pParent->Argument_Filament );
  56. pthread_exit(NULL);
  57. };
  59. // Demarrer() crée un filament qui execute le traitement avec passage de l'argument
  60. int x_Filament::Demarrer( void * argument ) {
  61.   Argument_Filament = argument;
  62.   int Valeur_Retour = pthread_create( &Identifiant_Filament, NULL, Filament, this );
  63.   return Valeur_Retour;
  64. };
  66. // Exemple de mise en oeuvre de classes dérivée de x_Filament.
  68. // Classe dérivée : x_MaClasse
  69. // (non suffisamment idiot pour faire comprendre qu'il s'agit d'un exemple). Cette classe décompte le temps qui passe (en secondes). Un compteur temporel est donc initialisé dans le constructeur et une fonction membre ::Traitement() assure l'auto-incrémentation du compteur temporel. Puisque cette classe dérive de x_Filament, une fois la fonction membre ::Demarrer() appelée, la fonction membre ::Traitement() s'exécute en parallèle du reste du code! Pour rendre cette classe un minimum "Thread-Safe", son écriture est légèrement chargée.   
  70. class x_MaClasse : public x_Filament
  71. {
  72. public:
  74. // Contructeur qui permet d'initialiser le compteur à une valeur quelconque
  75. x_MaClasse( long t ) {
  76.   lTempsInitial = lTemps = t;
  77.   pthread_mutex_init( &pmTemps, NULL ); }
  79. // Contructeur par recopie
  80. x_MaClasse( const x_MaClasse & c ) {
  81.   lTemps = c.lTemps;
  82.   lTempsInitial = c.lTempsInitial;
  83.   pmTemps = c.pmTemps; }
  85. // Fonction membre qui donne la valeur du compteur temporel
  86. long operator()() {
  87.   pthread_mutex_lock( &pmTemps );
  88.   long lValeurCourante = lTemps;
  89.   pthread_mutex_unlock( &pmTemps );
  90.   return lValeurCourante; }
  92. private:
  94. void Traitement( void * ) {
  95.   while( lTemps < ( lTempsInitial + 10 ) ) // on compte pendant 10s et on rend la main...
  96.   {
  97.     pthread_mutex_lock( &pmTemps );
  98.     lTemps++;
  99.     pthread_mutex_unlock( &pmTemps );
  100.     sleep(1);
  101.   }
  102. }
  104. long lTemps;
  105. long lTempsInitial;
  106. pthread_mutex_t pmTemps;
  107. };
  109. // Programme principal
  110. int main( int argc, char * argv[] )
  111. {
  113. // On instancie deux classes x_MaClasse : l'une démarre à -10s, l'autre à 90s.
  114. x_MaClasse monTemps10 = x_MaClasse(-10);
  115. x_MaClasse monTemps90 = x_MaClasse(90);
  117. // On démarre le filament (qui auto-incrémente le compteur temporel) de chaque classe.
  118. monTemps10.Demarrer( NULL );
  119. monTemps90.Demarrer( NULL );
  121. // On affiche régulièrement la valeur du compteur temporel de chaque classe
  122. while( true ) // <- PAS BIEN! Désolé!
  123. std::cout << "Etat des compteurs { " << monTemps10() << "s ; " << monTemps90() << "s }." << std::endl;
  125. // ...et pour la forme (hein?)
  126. return EXIT_SUCCESS;
  127. }


 
-edit-
RESOLU
Sous GNU/Linux, voici les problemes :
- Segmentation Fault au passage de l'instruction pthread_create(...).
- Impossible de linker certaines fonctions de pthread (pthread_join/detach entre autres).
RESOLU
-edit-
 
Merci d'avance pour vos conseils eclairés.
 
Cordialement,
   Xter.


Message édité par xterminhate le 01-02-2004 à 21:02:20
Reply

Marsh Posté le 28-01-2004 à 23:21:15   

Reply

Marsh Posté le 28-01-2004 à 23:22:31    

jète tout et passe par là -> boost.org :sol:
en plus c'est C++ orienté objet, un régal

Reply

Marsh Posté le 28-01-2004 à 23:28:26    

Oui j'y ai fortement pensé... mais je voulais tenter de comprendre par moi même.
 
D'ailleurs, je n'ai pas encore capté comment on exploite boost::, les sources sont ils disponibles ou faut il necessairement passer par leurs packages et leur outil de "compilation" (je ne sais meme pas le nommer).
 
Merci.
  XteR.

Reply

Marsh Posté le 28-01-2004 à 23:33:24    

non, les bordels compilés sont disponibles sur 2 nombreux systèmes.

Reply

Marsh Posté le 29-01-2004 à 00:11:34    

Tu as quelle version de boost ?

Reply

Marsh Posté le 29-01-2004 à 00:12:43    

1.30.2-2

Reply

Marsh Posté le 29-01-2004 à 08:39:26    

La nuit porte conseil ! Mon code tourne parfaitement sous GNU/Linux a condition de demander explicitement de linker avec POSIX Thread.... (hum! pas sérieux ca!)
 
Remarque : Par contre, je me demande toujours pourquoi pthread_create() est linkable sans la librairie POSIX (pthread.h). Ou est-elle déclarée ailleurs ? Pourquoi est-elle buggée en plus ?
 
Passons, je vais qd même essayer de comprendre boost.
 
Merci,
   Xter.

Reply

Marsh Posté le 29-01-2004 à 08:58:22    

bon, j'ai viré la partie win32 qui ne m'interresse pas.
le code suivant fonctionne.
ALors c'est vrai que boost c'est bien, mais le module de thread ne va pas forcément à tout le monde. Notemment, la fonction executée dans le thread n'est pas une fonction membre, et le mécanisme que xterminhate met en place avec la fonction virtuelle pure est sympathique, et va au dela de ce qui est proposé par boost.
Enfin, même si c'est bien de ne pas réinventer le moteur a explosion, certains ont quand même envie de comprendre comment cela se passe. Et dans ces cas, mettre les mains dedans c'est bien aussi.
 
Bon, sinon si tu as des pb de link, c'est que ta lib doit être foireuse. normalement, seul un -lpthread devreait suffir.
 

Code :
  1. // Librairies C++ & STL
  2. #include<string>
  3. #include<iostream>
  4.    
  5. // Librairies supplémentaires spéicifques Win32 ou GNU/Linux
  6. #include<unistd.h>
  7. #include<pthread.h>
  9.  
  10. #define THREAD_FUNCTION void *
  12.  
  13. // Classe de base : x_Filament exécute la fonction membre ::Traitement()
  14. //  de la classe dérivée. L'exécution de ::Traitement() met en oeuvre
  15. //  un filament (ou encore un 'thread' en anglais).
  16. //
  17. class x_Filament 
  18. {
  19. public:
  20.    
  21. // Demarrer() crée un filament qui execute le traitement avec passage de l'argument
  22. int Demarrer()
  23.  {
  24.   return pthread_create( &Identifiant_Filament, NULL, Filament, this );
  25.  }
  26.    
  27. protected:
  28. // Le code du filament à surcharger par la classe dérivée
  29. virtual void Traitement() = 0; 
  30.    
  31. private:
  32. // Le 'Thread' qui execute le traitement avec passage de l'argument
  33. static
  34. THREAD_FUNCTION Filament( void * pthis )
  35.  {
  36.   x_Filament * pParent = (x_Filament*)pthis;
  37.   pParent->Traitement();
  38.   pthread_exit(NULL);
  39.  }
  41. // L'identifiant du filament
  42. pthread_t Identifiant_Filament;
  43. };
  44.  
  45. // Exemple de mise en oeuvre de classes dérivée de x_Filament.
  46.  
  47. // Classe dérivée : x_MaClasse
  48. //  (nom suffisamment idiot pour faire comprendre qu'il s'agit d'un exemple).
  49. //  Cette classe décompte le temps qui passe (en secondes). Un compteur
  50. //  temporel est donc initialisé dans le constructeur et une fonction
  51. //  membre ::Traitement() assure l'auto-incrémentation du compteur temporel.
  52. //  Puisque cette classe dérive de x_Filament, une fois la fonction
  53. //  membre ::Demarrer() appelée, la fonction membre ::Traitement() s'exécute
  54. //  en parallèle du reste du code! Pour rendre cette classe un minimum
  55. //  "Thread-Safe", son écriture est légèrement chargée.
  56. //
  57. class x_MaClasse : public x_Filament
  58. {
  59. public:
  60.      
  61. // Contructeur qui permet d'initialiser le compteur à une valeur quelconque
  62. x_MaClasse( long t )
  63.  {
  64.   lTempsInitial = lTemps = t;
  65.   pthread_mutex_init( &pmTemps, NULL );
  66.  }
  67.    
  68. // Contructeur par recopie
  69. x_MaClasse( const x_MaClasse & c )
  70.  {
  71.   lTemps = c.lTemps;
  72.   lTempsInitial = c.lTempsInitial;
  73.   pmTemps = c.pmTemps;
  74.  }
  75.      
  76. // Fonction membre qui donne la valeur du compteur temporel
  77. long operator()()
  78.  {
  79.   pthread_mutex_lock( &pmTemps );
  80.   long lValeurCourante = lTemps;
  81.   pthread_mutex_unlock( &pmTemps ); 
  82.   return lValeurCourante;
  83.  }
  84.      
  85. private:
  86.      
  87. void Traitement()
  88.  {
  89.   while( lTemps < ( lTempsInitial + 10 ) ) // on compte pendant 10s et on rend la main...
  90.   {
  91.    pthread_mutex_lock( &pmTemps );
  92.    ++lTemps;
  93.    pthread_mutex_unlock( &pmTemps );
  94.    sleep(1);
  95.   }
  96.  }
  97.      
  98. long lTemps;
  99. long lTempsInitial;
  100. pthread_mutex_t pmTemps;
  101. };
  102.  
  103. // Programme principal
  104. int main( int argc, char * argv[] )
  105. {
  106.      
  107. // On instancie deux classes x_MaClasse : l'une démarre à -10s, l'autre à 90s.
  108. x_MaClasse monTemps10 = x_MaClasse(-10);
  109. x_MaClasse monTemps90 = x_MaClasse(90);
  110.      
  111. // On démarre le filament (qui auto-incrémente le compteur temporel) de chaque classe.
  112. monTemps10.Demarrer();
  113. monTemps90.Demarrer();
  114.      
  115. // On affiche régulièrement la valeur du compteur temporel de chaque classe
  116. while( true ) // <- PAS BIEN! Désolé!
  117. {
  118.  std::cout << "Etat des compteurs { " << monTemps10() << "s ; " << monTemps90() << "s }." << std::endl;
  119.  sleep(1);
  120. }
  121.      
  122. // ...et pour la forme (hein?)
  123. return 0;
  124. }


Reply

Marsh Posté le 29-01-2004 à 11:10:54    

oui mais c'est pourri comme code et ça fout en l'air les invariants du C++. tu peux te gratter pour tes destructeurs, autant carrémen tplus les écrire
 
x_MaClasse monTemps10 = x_MaClasse(-10);  
 
t'es sur que tu connais pas plus simple comme syntaxe ?
 
 
    « // ...et pour la forme (hein?)
     return 0; »
 
inutile

Reply

Marsh Posté le 29-01-2004 à 11:31:00    

> oui mais c'est pourri comme code
 
bien d'accord avec cet argument. Mais avant de passer à du code pondu par qq1 d'autre, c'est quand même bien de comprendre pourquoi ce qu'on a fait ne fonctionne pas, non? C'est frustrant de passer à autre chose sans avoir compris la cause des problèmes (qu'on est donc succeptible de reproduire par la suite).

Reply

Marsh Posté le 29-01-2004 à 11:31:00   

Reply

Marsh Posté le 29-01-2004 à 11:37:47    

le problème n'est pas là. c'est une approche C avec du C++. tu prends n'importe quelle implémentation de thread dans un langage objet (C++ pour nous), tout est emballé dans des classes.

Reply

Marsh Posté le 29-01-2004 à 12:45:41    

SoWhatIn22, je vois que tu as simplifié ma petite classe Thread. Je comptais le faire aussi et de cette façon là, mais je constaste que tu m'a pris de vitesse. Initialement, la fonction static ::filament se situait dans la classe, tu as corrigé de toi même, parfait.
 
Ce code avait un objectif pédagogique et je souhaite l'améliorer. Je suis prenneur de toutes observations constructives pour faire les améliorations qu'il convient.
 
Je regarde le code Thread.cpp de boost en comparaison, mais je ne pense pas utiliser directement boost (dans un premier temps) car c'est une librairie 'globale' dont 99% des fonctionnalités ne me sont pas utiles à l'heure actuelle.
 
Concernant le probleme des destructeurs... et bien je vais y regarder de plus pres. Jusqu'a maintenant, ce n'etait pas mon soucis principal.
 
Cordialement,
   Xter.


Message édité par xterminhate le 29-01-2004 à 12:49:32
Reply

Marsh Posté le 29-01-2004 à 12:56:10    

bah c'est toi qui voit, c'est toi qui supporte un mauvais design et ses problèmes. À au fait, n'utilise pas STL, parce que là t'es à 1% d'utilisation, ça vaut pas la peine

Reply

Marsh Posté le 29-01-2004 à 14:22:19    

SoWhatIn22 a écrit :


ALors c'est vrai que boost c'est bien, mais le module de thread ne va pas forcément à tout le monde. Notemment, la fonction executée dans le thread n'est pas une fonction membre, et le mécanisme que xterminhate met en place avec la fonction virtuelle pure est sympathique, et va au dela de ce qui est proposé par boost.


 
bin l'enorme avantage de la 'fonction' a executer par le thread chez boost et que ca peut etre un fonctor, on peut utiliser boost::bind pour utiliser des objets, tu peux envoyer une fonction avec des paramètres aussi.
 
puis rien ne t'empeche (il me semble ?) de dériver boost::thread pour pouvoir limiter l'utilisation à une méthode du fils comme ici.
 
sinon, la plupart des fontionnalités de boost s'ont pas besoin d'être compilées séparement, à 2-3 exceptions pres, boost::thread en fait partie. pour faciliter la compilation il existe l'utilitaire bjam.
 
edit : ca fait pas trop propagande ? :p


Message édité par blackgoddess le 29-01-2004 à 14:23:21

---------------
-( BlackGoddess )-
Reply

Marsh Posté le 29-01-2004 à 14:23:47    

bien dit. ce qui m'emmerde un peu, c'est que vous comprenez pas ce qu'implique de mixer du C avec du C++ : plus d'expcetion (si y en a une qui parre, c'est le plantage assuré), les destructeur ne sont pas appelés (risque de ne pas libérer des ressources, mais bien plus embêtant que la ram, ne pas libérer un mutex)
 
 
sinon je comprends rien : tu gueules parce qu'il faut passer par une classe, mais c'est toi qui fait une classe
 
 
 
et thread, ça se traduit pas par filament, mais tout simplement par « fil d'exécution »


Message édité par Taz le 29-01-2004 à 14:31:48
Reply

Marsh Posté le 29-01-2004 à 15:07:55    

> thread, ça se traduit pas par filament, mais tout simplement par « fil d'exécution »
 
tu vas un peu vite en besogne. Dans les mensuels (les journaux, quoi, genre LMF, Login, et autres), ca se traduit par "brin", "filament", "fil", et encore d'autres. De la possibilité de pouvoir choisir ... ("tous des cons", c'est ça?)
 
 
pour le reste, je lâche l'affaire...

Reply

Marsh Posté le 29-01-2004 à 15:10:34    

tous des cons. un thread en anglais, dans cet emploi, ne fais pas référence à de la couture ou autre chose, ce qui est important c'est l'exécution

Reply

Marsh Posté le 29-01-2004 à 15:12:15    

arrêtes, tu t'enfonces. ca va finir par se voir.

Reply

Marsh Posté le 29-01-2004 à 19:06:39    

Citation :

le problème n'est pas là. c'est une approche C avec du C++.


 
J'admets que la conception de ma classe Thread n'est pas 'top' (pas non plus 'bottom', enfin j'espere :) ). En outre, il faut reconnaitre également que les appels POSIX sont en pur C...
 
 

Citation :

...au fait, n'utilise pas STL, parce que là t'es à 1% d'utilisation, ça vaut pas la peine


 
Ca m'apprendra a sortir des arguments à la con! Même si seulement 1% de boost me concerne, cela ne devrait pas m'empecher de l'exploiter.  :jap:  
 
 

Citation :

sinon, la plupart des fontionnalités de boost s'ont pas besoin d'être compilées séparement, à 2-3 exceptions pres, boost::thread en fait partie. pour faciliter la compilation il existe l'utilitaire bjam.


 
Effectivement, thread.cpp se compile tout seul (quasiment)! D'ailleurs, je continue d'investiguer le code de Boost::Thread. Par contre, il me jette à la compilation (surement un pb de configuration des .H dédiés à la configuration de la plateforme).
 
 

Citation :

et thread, ça se traduit pas par filament, mais tout simplement par « fil d'exécution »


 
A partir du moment ou tout le monde se comprend, je pense que chacun est libre d'utiliser la traduction qui lui plait le plus plaisir. C'est bien a ça que sert le langage n'est ce pas...
 
Merci pour vos commentaires sur ma classe, je tente de l'améliorer tout en gardant une approche pédagogique.
 
Xter.
 
PS: Et arretez de vous insulter !  :non:  C'est sûr, nous n'avons pas tous le même niveau en programmation... c'est qd même pas bien grave surtout si la volonté de progresser est là !


Message édité par xterminhate le 29-01-2004 à 19:08:10
Reply

Marsh Posté le 29-01-2004 à 19:30:30    

Je persiste à dire qu'utiliser les pthread en C++ de cette manière, c'est aller droit dans le mur. aurevoir

Reply

Marsh Posté le 29-01-2004 à 22:28:22    

Je viens de parcourir un peu plus en détail le code source de boost:thread. C'est un fait : l'"emballage" est nettement mieux fait dans boost.
 
Reste bien assis Taz, parce que sincèrement je ne vois pas de différence fondamentale entre mon code et celui de boost. Ou alors, c'est vraiment subtile! Avant de m'insulter en ligne (sic!), je continue mon investigation, sait-on jamais ;)
 
Cordialement,
   Xter.

Reply

Marsh Posté le 30-01-2004 à 00:06:39    

je suis preneur si tu as un code qui tourne --> PV

Reply

Marsh Posté le 30-01-2004 à 00:32:30    

Je finalise et je te transmets le code.
 
Par ailleurs, je commence à comprendre! Par exemple, un constructeur par recopie n'a aucun sens avec ma classe Thread alors que dans boost::Thread ca marche impec. Cette dernière respecte en effet la conception OO.
 
On va dire que ma classe s'utilise différement...
 
Cordialement,
   Xter.

Reply

Marsh Posté le 30-01-2004 à 01:52:03    

J'en suis arrivé là. Je conserve mon interface (non c++) du début. Je me suis inspiré du code de boost et d'autres librairies. Ca vaut ce que ca vaut. Si vous trouvez un bug, signalez le moi. Merci.
 
Cordialement,
 Xter.
 
 
Les librairies...
 

Code :
  1. // Librairies C++
  2. #include<string>
  3. #include<iostream>
  5. // Librairies supplémentaires  
  6. #ifdef WIN32
  7. #include<process.h>
  8. #else
  9. #include<unistd.h>
  10. #include<pthread.h>
  11. #endif


 
La classe...
 

Code :
  1. // Classe de base filament
  2. class x_Filament
  3. {
  4. public:
  6. // Constructeur
  7. x_Filament();
  9. // Constructeur par recopie
  10. x_Filament( const x_Filament & );
  12. // Destructeur
  13. virtual ~x_Filament();
  15. // Démarre le filament.
  16. void Demarrer();
  18. // Traitement exécuté par le filament
  19. // (A SURCHARGER PAR CLASSE DERIVEE).
  20. virtual void Traitement() = 0;
  22. // Arrète le filament.
  23. void Arreter();
  25. // Attendre la fin du filament.
  26. void Attendre();
  28. // Etat du filament
  29. bool bExecution;
  31. private:
  33. // Filament
  34. #ifdef WIN32
  35. static unsigned __stdcal Filament( void * pthis );
  36. #else
  37. static void * Filament( void * pthis );
  38. #endif
  40. // Identifiants
  41. #ifdef WIN32
  42. HANDLE Identifiant_Filament;
  43. unsigned int Identifiant_Filament_Win32;
  44. #else
  45. pthread_t Identifiant_Filament;
  46. #endif
  47. };


 
Les implémentations....
 

Code :
  1. #ifdef WIN32
  2. unsigned __stdcall x_Filament::Filament( void * pthis ) {
  3. #else
  4. void * x_Filament::Filament( void * pthis ) {
  5. #endif
  6. try
  7. {
  8.  x_Filament * pParent = (x_Filament*)pthis;
  9.  pParent->bExecution = true;
  10.  pParent->Traitement();
  11. }
  12. catch(...)
  13. {
  14. }
  15. #ifdef WIN32
  16. return(0);
  17. //_endthreadex(0);
  18. #else
  19. pthread_exit(0);
  20. #endif
  21. }
  23. x_Filament::x_Filament() : bExecution( false ) { }
  25. x_Filament::~x_Filament() {
  26. if( bExecution )
  27. {
  28.  #ifdef WIN32
  29.  int resultat;
  30.  resultat = CloseHandle( Identifiant_Filament );
  31.  if( resultat == 0 )
  32.   std::cout << std::endl << "Erreur avec CloseHandle()! Error = "  << GetLastError() << "." << std::endl;
  33.  #else
  34.  pthread_detach( Identifiant_Filament );
  35.  #endif
  36. }
  37. }
  39. void x_Filament::Demarrer() {
  40. if( !bExecution )
  41. {
  42.  #ifdef WIN32
  43.  Identifiant_Filament = (HANDLE)_beginthreadex( NULL, 0, &Filament, this, 0, &Identifiant_Filament_Win32 );
  44.  if( Identifiant_Filament == 0 )
  45.   std::cout << std::endl << "Erreur avec _beginthread()!"  << std::endl;
  46.  #else
  47.  int valeur = pthread_create( &Identifiant_Filament, 0, Filament, this );
  48.  if( valeur != 0 )
  49.   std::cout << std::endl << "Erreur avec pthread_create()!"  << std::endl;
  50.  #endif
  51. }
  52. }
  54. void x_Filament::Arreter() {
  55. if( bExecution ) {
  56.  #ifdef WIN32
  57.  TerminateThread( Identifiant_Filament, 0 );
  58.  #else
  59.  pthread_cancel( Identifiant_Filament );
  60.  #endif
  61.  bExecution = false;
  62. }
  63. }
  65. void x_Filament::Attendre() {
  66. if( bExecution ) {
  67.  #ifdef WIN32
  68.  int resultat;
  69.  resultat = WaitForSingleObject( Identifiant_Filament, INFINITE );
  70.  if( resultat != WAIT_OBJECT_0 )
  71.   std::cout << std::endl << "Erreur avec WaitForSingleObject()! Error = " << GetLastError() << "." << std::endl;
  72.  resultat = CloseHandle( Identifiant_Filament );
  73.  if( resultat == 0 )
  74.   std::cout << std::endl << "Erreur avec CloseHandle()! Error = "  << GetLastError() << "." << std::endl;
  75.  #else
  76.  if( pthread_join( Identifiant_Filament, NULL ) != 0 )
  77.   std::cout << std::endl << "Erreur avec pthread_join()!"  << std::endl;
  78.  #endif
  79.  bExecution = false;
  80. }
  81. }


Message édité par xterminhate le 30-01-2004 à 02:13:46
Reply

Marsh Posté le 30-01-2004 à 04:50:05    

Bon j'ai tenté d'ajouter une ptite surcouche C++ à ma classe x_Filament. Je l'appelle x_Filament_Ameliore et elle prend en argument un functor....
 

Code :
  1. template< class foo >
  2. class x_Filament_Ameliore : public x_Filament
  3. {
  4. public:
  6. x_Filament_Ameliore( const foo & f ) : functor(f)
  7. { Demarrer(); }
  9. void Traitement() { functor(); };
  11. private:
  13. const foo & functor;
  15. };


Message édité par xterminhate le 30-01-2004 à 04:58:48
Reply

Marsh Posté le 30-01-2004 à 05:03:17    

Je me demande pourquoi je m'ennuis... je retombe exactement sur boost.... :p

Reply

Marsh Posté le 30-01-2004 à 12:32:53    

En m'inspirant fortement de LMF janvier 2004, voila ce que pourrait donner une adaptation C++ de ma classe thread.
 

Code :
  1. template< class _C, typename _METHODE_TYPE >
  2. class x_Filament_Ameliore : public x_Filament
  3. {
  4. public:
  5. x_Filament_Ameliore( _C* c, void(_C::*m)() )
  6. { Connect(c,m); Demarrer(); }
  8. x_Filament_Ameliore( _C* c, void(_C::*m)() const)
  9. { Connect(c,m); Demarrer(); }
  11. void Traitement() { (in_class->*methode)(); };
  13. private:
  15. void Connect(_C* c, _METHODE_TYPE m)
  16. { in_class = c; methode = m; }
  18. _C* in_class;
  19. _METHODE_TYPE methode;
  20. };


 
Quant à l'utilisation, c'est extremement bourin mais ca permet d'executer en filament n'importe quelle fonction membre de n'importe quelle classe (à condition de la fonction membre retourne void). De ce genre...
 

Code :
  1. class maclasse
  2. {
  3. void operator() () const { /*...*/ }
  4. }


 

Code :
  1. maclasse foo;
  2. x_Filament_Ameliore<maclasse , void (maclasse ::*)() const> fildexecution(&foo, &foo::operator());
  3. // le filament démarre ici et execute de manière concurente la fonction memebre passée en argument : void maclasse()....


 
Cordialement,
   Xter.

Reply

Marsh Posté le 30-01-2004 à 12:47:38    

Je me demande ce qu'il se passe si le destructeur de la classe foo est appelé avant la fin de l'execution du filament( qui execute void foo() )... hum!

Reply

Marsh Posté le 30-01-2004 à 16:38:49    

xterminhate a écrit :

Par exemple, un constructeur par recopie n'a aucun sens avec ma classe Thread alors que dans boost::Thread ca marche impec. Cette dernière respecte en effet la conception OO.


 
bin ... boost::thread hérite de boost::noncopyable, ce qui empêche l'objet d'etre copié, ce qui n'a effectivement aucun sens dans le cas d'un thread :p


---------------
-( BlackGoddess )-
Reply

Marsh Posté le 30-01-2004 à 17:28:35    

Tout a fait, boost empeche l'utilisateur ne faire n'importe quoi avec la classe boost::Thread une fois instanciée... Par curiosité il faudra que je jete un coup d'oeil furtif dans la description de boost:noncopyable histoire de voir comment elle marche. Apparement tu as l'air assez friand de cette classe d'apres ce que j'ai pu constaté :)
 
Merci,
   Xter.
 

Reply

Marsh Posté le 31-01-2004 à 03:40:07    

lool oui, bin c'est pratique je trouve en effet :p
puis elle est super simple cette classe : elle se contente de déclarer le constructeur de copie et l'operateur d'assignation en privée :)


---------------
-( BlackGoddess )-
Reply

Marsh Posté le 01-02-2004 à 21:01:34    

Pour en terminer avec ce post, le code source de mon thread c++ est disponible à l'adresse suivante.
 
http://www.cppfrance.com/code.aspx?ID=19908
 
Je ferai probablement des mises à jour pour améliorer ou corriger ce code.
 
Cordialement,
   XteR.

Reply

Marsh Posté le    

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed