some-usable-scripts/C_Language/TP_SYS/Exemples_semaphores/ecrireZ_Sem.c

115 lines
2.3 KiB
C

/* Mecanismes de communication entre processus - IPC */
/* Ecriture dans une zone de mémoire partajée (shared memory - shm ) */
// VERSION AVEC SEMAPHORE
#include <stdlib.h>
#include <stdio.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#define SHMEM_SIZE 0xff
#define SHMEM_RIGHTS 0x01ff
void erreur(char *mess);
int main (int argc, char ** argv) {
long i , k , temp;
long * ptz ;
int p1 , p2, p3, p4;
int ipc_key, ipc_result ;
int mutex; // id du semaphore
if (argc<2)
exit(1) ;
ipc_key = atoi(argv[1]) ;
ipc_result = shmget(ipc_key, 0 , 0) ; // ouverture mémoire partagée
ptz = (long *) shmat(ipc_result, 0, SHMEM_RIGHTS) ; // attachement mémoire partagée
// creation du semaphore mutex
if((mutex = creat_sem(ipc_key+1,1)) == -1)
erreur("erreur creation semaphore");
if ((p1 = fork()) == 0) {
for(i=0;i<10;i++) {
P(mutex); //__________________________
temp = * ptz;
temp++;
sleep( rand() % 2 ); // attente aléatoire
*ptz = temp; ;
V(mutex); //________________________________
//(*ptz) ++ ;
}
exit(0) ;
}
if ((p2 = fork()) == 0) {
for(i=0;i<10;i++) {
P(mutex); //__________________________
temp = * ptz;
temp++;
sleep( rand() % 2 ); // attente aléatoire
*ptz = temp;
V(mutex); //________________________________
}
exit(0) ;
}
if ((p3 = fork()) == 0) {
for(i=0;i<10;i++) {
P(mutex); //__________________________
temp = * ptz;
temp++;
sleep( rand() % 2 ); // attente aléatoire
*ptz = temp;
V(mutex); //________________________________
//(*ptz) ++ ;
}
exit(0) ;
}
if ((p4 = fork()) == 0) {
for(i=0;i<10;i++) {
P(mutex); //__________________________
temp = * ptz;
temp++;
sleep( rand() % 2 ); // attente aléatoire
*ptz = temp; ;
//(*ptz) ++ ;
V(mutex); //________________________________
}
exit(0) ;
}
// while(wait(0) != -1); si le père attend que tous ses fils soient terminés
// suppression du semaphore
//del_sem(mutex);
printf("\n Arret processus pid = %d compteur ( %d ) \n\n", getpid(), *ptz) ;
exit(0) ;
}