Notions de taches, semaphores et sections critiques.

Commenter

Contenu du snippet

Ce programme peut servir à comprendre comment fonctionne les taches unix, et comment protéger les variables globales partagées entre taches grace à des semaphores.

Source / Exemple : 


/* ---------------------------------------------------------------------------


     
  •  Programme utilisant des threads (taches)

    •  
  •  Auteurs    : fgazier

    •  
  •  Création   : 15/10/03

    •  
  •  Entrées    : --

    •  
  •  Sorties    : écran

    •  
  •  Avancement : OK et testé

    •  
  •  -------------------------------------------------------------------------*/


#include <stdio.h>
#include <unistd.h>
#include <pthread.h>
#include <semaphore.h>

int globale = 0;

typedef struct {
  int valAdd;
  sem_t * sem;
} Sem_et_int;

void * malloc (size_t size);
void free (void * ptr);

void * addNumtachVarglob(void *pointStruc);

/* ---------------------------------------------------------------------------


     
  •  Nom de la fonction : Main

    •  
  •  But : Créer dix taches (thread) utilisant une variable globale et protège

    •  
  • 	l'accès en parrallèle des taches sur la variable globale grace à 

    •  
  • 	l'utilisation d'un Sémaphore. 

    •  
  •  -------------------------------------------------------------------------*/	 		 

int main(void)
{
  int i;
  sem_t semaphore_i;
  Sem_et_int * ind[10];
  pthread_t thr[10];

  i = 1;

  if (sem_init(&(semaphore_i), 0, 1) == -1)
   {
     printf("Erreur à la création d'un sémaphore.\n");
     return 0;
   }
   
  while (i != 11)
   {
     ind[i]=malloc(sizeof(Sem_et_int));
     (*ind[i]).valAdd = i;
     (*ind[i]).sem = &semaphore_i;
     pthread_create(&thr[i], NULL, addNumtachVarglob,(void *) ind[i]);
     i++;
   }
  
  sleep(11);
  
  printf("La variable globale est égale à %d\n", globale);

  if (sem_destroy(&(semaphore_i)) == -1)
   {
     printf("Erreur à la destruction du sémaphore.\n");
     return 0;
   }

  return 0;
}

/* ---------------------------------------------------------------------------


     
  •  Nom de la fonction : addNumtachVarglob

    •  
  •  But : Cette fonction est exécutée par toutes les taches. Elle doit ajouter

    •  
  •     	des valeurs qu'on lui transmet en paramètre, à la variable globale, 

    •  
  •  	tout en protégeant les sections critiques par des sémaphores.

    •  
  •  Paramètres entrées/sortie : La fonction reçoit en entrée un pointeur sur 

    •  
  • 	"n'importe quoi = VOID", et ne renvoit rien en sortie.

    •  
  •  Précondition : La structure sur laquelle pointe le pointeur sur Void, 

    •  
  •  	doit etre "correctement" instanciée.

    •  
  •  -------------------------------------------------------------------------*/

void *addNumtachVarglob(void *pointStruc)
{ 
  Sem_et_int *point;
  point = pointStruc;
  printf("Tache %d rentre dans le semaphore.\n", (*point).valAdd);
  
  /* Verrouillage des variables globales */
  sem_wait((*point).sem);
  
  {
  int locale = globale;
  sleep(1);
  printf("Var glob = : %d \n", (*point).valAdd);
  locale += (*point).valAdd;
  globale = locale;
  }
  
  /* Deverrouillage des variables globales */
  sem_post((*point).sem);
  
  printf("Tache %d est sortie du semaphore\n", (*point).valAdd);
  free(point);
  
  return NULL;
}

Conclusion :


Aucun bug connus (vérification ayant été minutieuse)

A voir également

S'inscrire maintenant

Vous n'êtes pas encore membre ?

inscrivez-vous, c'est gratuit et ça prend moins d'une minute !

Les membres obtiennent plus de réponses que les utilisateurs anonymes.

Le fait d'être membre vous permet d'avoir un suivi détaillé de vos demandes et codes sources.

Le fait d'être membre vous permet d'avoir des options supplémentaires.

Du même auteur (fgazier)