include pthread include stdio include unistd include math include stdl

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
#include <pthread.h>
#include <stdio.h>
#include <unistd.h>
#include <math.h>
#include <stdlib.h>
#include <semaphore.h>
#define M 4
#define N 3
unsigned int iter;
sem_t accessM,readresM,orderM;
unsigned int readers = 0;
void *reader(void *prm)
{
int num1=*(int*)prm;
int i=0,r;
for(i;i<iter;i++)
{
if (sem_wait(&orderM)==0) printf("%d Читатель %d в очереди__________Ч%d\n",i,num1,num1);
sem_wait(&readresM);
if (readers == 0)
sem_wait(&accessM);
readers++;
sem_post(&orderM);
sem_post(&readresM);
printf("%d Работает читатель %d________________Ч%d\n",i,num1,num1);
r=1+rand()%4;
sleep(r);
sem_wait(&readresM);
readers--;
if (readers == 0)
sem_post(&accessM);
sem_post(&readresM);
}
}
void *writer(void *prm)
{
int num2=*(int*)prm;
int j=0,r;
for(j;j<iter;j++)
{
if(sem_wait(&orderM)==0) printf("%d Писатель %d в очереди__________П%d\n",j,num2,num2);
sem_wait(&accessM);
sem_post(&orderM);
printf("%d Работает писатель %d________________П%d\n",j,num2,num2);
r=1+rand()%4;
sleep(r);
sem_post(&accessM);
}
}
int main()
{
pthread_t threadRE[N];
pthread_t threadWR[M];
sem_init(&accessM,0,1);
sem_init(&readresM,0,1);
sem_init(&orderM,0,1);
printf("Введите количество итераций: ");
scanf("%d",&iter);
printf("Iter ОЧЕРЕДЬ/ВЫПОЛНЕНИЕ\n");
int i;
for(i=0;i<M;i++)
{
pthread_create(&(threadWR[i]),NULL,writer,(void*)&i);
}
for(i=0;i<N;i++)
{
pthread_create(&(threadRE[i]),NULL,reader,(void*)&i);
}
for(i=0;i<N;i++)
{
pthread_join(threadRE[i],NULL);
}
for(i=0;i<M;i++)
{
pthread_join(threadWR[i],NULL);
}
sem_destroy(&accessM);
sem_destroy(&readresM);
sem_destroy(&orderM);
return 0;
}