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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
| #include <stdio.h>
#include <conio.h>
#include <windows.h>
#include <ctime>
#define BufferSize 10
#define Producers 1
#define Consumers 1
int t_takt;
int kolvo_takt,key,key2;
int scoro=500;
int chet_obs=0;
int chet_pr=0;//произвели
int chet_pok=0;//прочитали
int buf=0;
int buf1=0;
int chet=0;
int Buffer[BufferSize];
bool Trans,Trans1,perepol;
HANDLE hFull, hEmpty, hMutex; //дескриптор создаваемых потоков
void VIVOD()//функция мониторинга
{ int i;
if(chet_obs>=t_takt)
{buf=0;
for (i=BufferSize-1; i >= 0; i--)
{
if (Buffer[i]!=0) buf=++buf;
printf("%d", Buffer[i]);}
printf("\n");
printf("Zaderka: %d\n", scoro);
printf("proizvel: %d\n",chet_pr);
printf("c4ital %d\n",chet_pok);
printf("V buffere: %d\n", buf);
printf("\n");
chet_obs=0;
chet_pr=0;
chet_pok=0;
buf=0;
}
}
DWORD WINAPI Klava(void * pValue)//потоковая функция ввода с клавиатуры
{
while(Trans1){
if ((GetKeyState(VK_NUMPAD1)==1)&(key==-32768))
{scoro=scoro+100;}
if ((GetKeyState(VK_NUMPAD2)==1)&(key2==-32768))
{if (scoro<=0) scoro=0; else scoro=scoro-100;}
key=GetAsyncKeyState(VK_NUMPAD1);//функция определяет состояние клавишии и была ли клавиша нажата после предыдущего вызова этой функции
key2=GetAsyncKeyState(VK_NUMPAD2);
}
}
DWORD WINAPI Producer(void * pValue)//потоковая функция производителя
{
int Value, i;
Trans = true;
while (kolvo_takt>0)
{
VIVOD();
chet_obs++;
kolvo_takt--;
srand((unsigned)time(NULL));
Value = rand()%9+1;
WaitForSingleObject(hEmpty, INFINITE);//ждем своего события
WaitForSingleObject(hMutex, INFINITE);//ждем своего события
chet_pr++;
for (i=BufferSize-2; i >= 0; i--)
Buffer[i+1]=Buffer[i];
Buffer[0]=Value;
ReleaseSemaphore(hMutex, 1, NULL);//установка(освобождение семафора)
ReleaseSemaphore(hFull, 1, NULL);
Sleep(500);//задержка
}
}
DWORD WINAPI Consumer(void * pValue)//потоковая функция потребителя
{
int Value, i, Count;
while(Trans)
{
VIVOD();
chet_obs++;
WaitForSingleObject(hFull, INFINITE);
WaitForSingleObject(hMutex, INFINITE);
for (i=BufferSize-1; i>=0; i--)
if (Buffer[i]!=0)
{
chet_pok++;
buf1++;
break;
}
Value=Buffer[i];
Buffer[i]=0;
ReleaseSemaphore(hMutex, 1, NULL);
ReleaseSemaphore(hEmpty, 1, NULL);
Sleep(scoro);
}
}
int main(void)
{
HANDLE hThreads[Producers+Consumers+1];//дескриптор
DWORD ThreadId;//идентификатор потока
int i;
Trans1=1;
printf("Vremya takta\n");
scanf("%d", &t_takt);
printf("Kolichestvo taktov\n");
scanf("%d", &kolvo_takt);
perepol=0;
hEmpty=CreateSemaphore(NULL, BufferSize, BufferSize,"Empty");
hMutex=CreateSemaphore(NULL, 1, 1,"Mutex");
hFull=CreateSemaphore(NULL, 0, BufferSize ,"Full");
for (i=0; i<BufferSize; i++) Buffer[i]=0;//обнуление буфера
hThreads[0]=CreateThread(0,0,Producer,0,0,&ThreadId);//создаем потоки, выполняемыеы в пределах виртуального адресного пространства выхывающего процесса
hThreads[1]=CreateThread(0,0,Consumer,0,0,&ThreadId);
hThreads[2]=CreateThread(0,0,Klava,0,0,&ThreadId);
WaitForMultipleObjects(Producers,hThreads,true,INFINITE);//функция ожидания(для организации синхронизации)(блокировка процессов для работы одного)
Trans1=false;
Trans=false;
WaitForMultipleObjects(Producers+Consumers, hThreads, true, INFINITE);
WaitForMultipleObjects(Producers+Consumers+1, hThreads, true, INFINITE);
for (i=0; i<Producers+Consumers+1; i++)
CloseHandle(hThreads[i]);
CloseHandle(hMutex);
CloseHandle(hFull);
CloseHandle(hEmpty);
} |
(
