---

Interface de gestion de threads
[Interface FRED]

Ce module définit comment créer des threads, terminer un thread ou un programme concurrent et connaitre le thread courant. Plus de détails...

Définitions des macros
#define	FredTHREAD_NIL   (FredThread)NIL
	Définition du thread inexistant.
Définitions des types
typedef void *(*	FredRunnable )(void *)
	Le type d'une procédure initiale de thread.
typedef FredThreadDesc *	FredThread
	L'identité d'un thread est un pointeur sur son descripteur.
typedef FredList	FredQueue
	Définition du type queue de threads.
Fonctions
FredThread	FredThreadSpawn (int stacksz, FredRunnable function, void *arg, void **resref)
	Création et lancement d'un thread.
void	FredThreadExit (void *res)
	Terminaison immédiate du thread courant.
void	FredThreadYield ()
	Le thread courant passe la main à un autre thread.
FredThread	FredThreadCurrent ()
	Rend l'identité du thread courant.

---

Description détaillée

Pour savoir comment l'utiliser, voir Gestion des threads et Les N philosophes

---

Documentation de la macro

#define FredTHREAD_NIL   (FredThread)NIL

Implantation C'est un simple alias du pointeur nul de cellule de liste

---

Documentation du type

typedef FredList FredQueue

Implantation C'est un simple alias d'une liste.

---

Documentation de la fonction

FredThread FredThreadCurrent (    )

Renvoie : l'adresse du descripteur du thread actif Implantation { return current; }

void FredThreadExit (  void *    res )

Paramètres: res  adresse du résultat du calcul du thread Implantation On rend le résultat à l'endrioit défini au mau moment de la création du thread par FreedThreadSpawn() . Le thread est mis dans la file des décédés pour que sa mémoire soit libérer par leon { FredThread old; FredCountDownStop();/* arrêt décomptage */ /* mettre le résultat à l'endroit demandé */ if(current->resref)*(current->resref)=res; FredMaskOn();/* début d'exclusion mutuelle */ /* réveil de leon */ FredThreadWakeUp(&leonQ); /* un thread ne peut libérer la mémoire dans laquelle il s'exécute. Il délègue cela a leon en s'inscrivant dans la file des threads défunts */ FredThreadSuspend(&deadQ); /* on ne revient jamais ici */ FredAbort(" erreur fatale dans threadDie"); }

FredThread FredThreadSpawn (  int    stacksz, FredRunnable    function, void *    arg, void **    resref )

Paramètres: stacksz  taille de pile exigée pour le thread function  fonction à exécuter par le thread arg  adresse de l'argument de la fonction resref  Si l'adresse resref est non nulle, on y mettra l'adresse du résultat de la fonction lorsque le thread créé terminera. Renvoie : l'adresse du descripteur du thread créé ou FredTHREAD_NIL (0) Implantation On alloue la mémoire pour un descripteur de thread et la pile (éventuellement arrondi ). Si cette étape est franchi avec succès, on initialise le descripteur du thread ( FredThreadDesc ) et son contexte. On l'insère enfin dans la file des prêts readyQ en incrémentant le nombre de threads vivants nbFredThreads . { FredThread nw; /* allocation d'un descripteur de thread si possible */ nw= FredNEW(FredThreadDesc) ; if(!nw) return nw; /* calcul taille de pile */ nw->stacksz=FredSTACK_SIZE(stacksz); /* allocation de la pile si possible */ if(!(nw->stack=(char*)FredAtomicAlloc(nw->stacksz))) { /* plus de mémoire */ FredDELETE( nw); return FredTHREAD_NIL; } /* initialisation du descripteur */ nw->err=0; /* init errno à OK */ nw-> entry=function; /* fonction à exécuter */ nw->val=arg; /* son argument */ nw->resref=resref; /* où mettre le résultat */ /* initialisation du contexte processeur du thread */ FredContextInit(nw->ctx, FredMAKE_SP(nw->stack,nw->stacksz), FredThreadHarness); FredMaskOn();/* début d'exclusion mutuelle */ FredQueuePutLast(&readyQ,nw);/* réveil du nouveau thread */ nbFredThreads++; /* un thread de plus !! */ FredMaskOff();/* fin d'exclusion mutuelle */ return nw; }

void FredThreadYield (    )

Implantation { FredThread old; FredMaskOn(); /* début d'exclusion mutuelle */ current->err=errno; /* sauver errno */ FredCountDownStop();/* arrêt décomptage */ old=current; /* le courant se met en queue des prêts */ /* on tire un nouveau courant */ FredQueuePutLast(&readyQ,current); current=FredQueueGetFirst(&readyQ); /* traiter le cas d'un unique thread actif : rien faire */ if(current!=old)FredContextSwitch(old->ctx,current->ctx); /* on reviendra ici lors de son réveil : on relance le décomptage du quantum */ FredCountDownStart(quantum);/* lancer décomptage */ errno=current->err;/* restaurer errno */ FredMaskOff();/* fin d'exclusion mutuelle */ }

---