Changeset 25
- Timestamp:
- Apr 13, 2013, 4:53:54 PM (12 years ago)
- Location:
- trunk
- Files:
-
- 1 added
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/threads-sem.c
r2 r25 9 9 #include <semaphore.h> 10 10 11 void enter_section(sem_t *s){11 void down(sem_t *s){ 12 12 if (sem_wait(s) < 0){ 13 13 perror("Errore semaforo (down)"); … … 16 16 } 17 17 18 19 20 void leave_section(sem_t *s) 21 { 18 void up(sem_t *s){ 22 19 if (sem_post(s) < 0){ 23 20 perror("Errore semaforo (up)"); … … 26 23 } 27 24 28 int run(const int p, void* s) 29 { 30 int* shared = (int*)s; /* alias per comodita` */ 31 while (enter_section((sem_t*)shared[1]), 32 shared[0] < 10) { 25 int shared = 0; 26 pthread_t p1, p2; 27 sem_t ss; 28 29 void* run(void* s){ 30 while (down(&ss), 31 shared < 10) { 33 32 sleep(1); 34 printf("Processo figlio (%d). s = %d\n",35 getpid(), shared[0]);36 if (!(shared [0]< 10)){33 printf("Processo thread (%p). s = %d\n", 34 pthread_self(), shared); 35 if (!(shared < 10)){ 37 36 printf("Corsa critica!!!!\n"); 38 37 abort(); 39 38 } 40 shared [0]+= 1;41 leave_section((sem_t*)shared[1]);42 sched_yield();39 shared += 1; 40 up(&ss); 41 pthread_yield(); 43 42 } 44 return 0; 43 up(&ss); 44 return NULL; 45 45 } 46 46 47 int run0(void*s){ return run(0, s); } 48 int run1(void*s){ return run(1, s); } 49 47 50 48 51 49 int main(void){ 52 53 int shared[4] = {0 , 0, 0, 0};54 50 55 sem_t *ss; 56 if (sem_init(ss, 51 if (sem_init(&ss, 57 52 0 /* thread local semaphore */, 58 0/* init value */53 1 /* init value */ 59 54 ) < 0){ 60 55 perror("Errore semaforo"); 61 56 exit(1); 62 57 } 63 shared[1] = (int)ss;64 58 65 /* int clone(int (*fn)(void *), 66 * void *child_stack, 67 * int flags, 68 * void *arg); 69 * crea una copia del chiamante (con le caratteristiche 70 * specificate da flags) e lo esegue partendo da fn */ 71 if (clone(run0, /* il nuovo 72 * processo esegue run(shared), vedi quarto 73 * parametro */ 74 malloc(4096)+4096, /* lo stack del nuovo processo 75 * (cresce verso il basso!) */ 76 CLONE_VM | SIGCHLD, /* la (virtual) memory e` condivisa */ 77 shared) < 0){ 78 perror("Errore nella creazione"); 79 exit(1); 80 } 59 pthread_create(&p1, NULL, run, NULL); 60 pthread_create(&p2, NULL, run, NULL); 81 61 82 if (clone(run1, malloc(4096)+4096, CLONE_VM | SIGCHLD, shared) < 0){ 83 perror("Errore nella creazione"); 84 exit(1); 85 } 86 87 /* Memoria condivisa: i due figli nell'insieme eseguono 10 o 88 * 11 volte: e` possibile una corsa critica. Il padre 89 * condivide shared[0] con i figli */ 90 91 while(shared[0] < 10) { 92 sleep(1); 93 printf("Processo padre. s = %d %d %d %d\n", 94 shared[0], 95 shared[1], 96 shared[2], 97 shared[3]); 98 } 99 sem_destroy(ss); 62 pthread_join(p1, NULL); 63 pthread_join(p2, NULL); 64 65 sem_destroy(&ss); 66 100 67 return 0; 101 68 }
Note:
See TracChangeset
for help on using the changeset viewer.