» Вопросы по программированию на C/С++

ну всем как бы присутсвующим

конкретный вопрос :)

ну у вас же какие то соображения есть.
вот мне положим AVX на фиг не нужно - процессор не поддерживает, а в изучениях я на втором sse застрял, с другой стороны не пропомню ни единого случая чтоб мне .186 .286 директивы в серьез понадобились. так что 10 версией все таки логичнее пользоваться, масма в смысле

Здравствуйте, помогите разобраться;

Задание: Реализовать схему "оповещения" трех ожидающих потоков о помещении в очередь (произвольного формата) некоторого сообщения на основе объекта синхронизации "событие". Генерируют события в очередь два потока, которые имеют приоритет на уровень ниже, чем ожидающие. Посчитать среднее число обработанных каждым потоком сообщений. Очередь должна быть защищена критической секцией.

[more=Код моей программы]
Код: #include <cstdlib>
#include <iostream>
#include <windows.h>

using namespace std;

HANDLE hTimer;
HANDLE hIEvent[2];
HANDLE hOEvent[3];
HANDLE hThread[5];
LPDWORD lpThreadId[5];
int count, s[3];
int arr[10];
RTL_CRITICAL_SECTION cs;
DWORD hTimerWait;
const LARGE_INTEGER *li;

void LastErrorMessage(int LastErrorCode){
cout << "Error Code: " << LastErrorCode << endl;
return;
}

DWORD InputThread1(){
hTimerWait = WaitForSingleObject(hTimer, 100);
while(hTimerWait==WAIT_TIMEOUT){

WaitForMultipleObjects(3, hOEvent, FALSE, INFINITE);
EnterCriticalSection(&cs);
if(count<11){
count++;
arr[count]=1;

cout << "InputThread 1: " << arr[count] << endl;
}
LeaveCriticalSection(&cs);
SetEvent(hIEvent[0]);
}
return true;
}
DWORD InputThread2(){
hTimerWait = WaitForSingleObject(hTimer, 100);
while(hTimerWait==WAIT_TIMEOUT){

WaitForMultipleObjects(3, hOEvent, FALSE, INFINITE);
EnterCriticalSection(&cs);
if(count<11){
count++;
arr[count]=2;

cout << "InputThread 2: " << arr[count] << endl;
}
LeaveCriticalSection(&cs);
SetEvent(hIEvent[1]);
}
return true;
}
DWORD OutputThread1(){
hTimerWait = WaitForSingleObject(hTimer, 100);
while(hTimerWait==WAIT_TIMEOUT){

WaitForMultipleObjects(2, hOEvent, FALSE, INFINITE);
EnterCriticalSection(&cs);
if(count>0){
cout << "OutputThread 1: " << arr[count] << endl;
arr[count]=0;
count--;
s[0]++;
}
LeaveCriticalSection(&cs);
SetEvent(hOEvent[0]);
}
return true;
}
DWORD OutputThread2(){
hTimerWait = WaitForSingleObject(hTimer, 100);
while(hTimerWait==WAIT_TIMEOUT){

WaitForMultipleObjects(2, hOEvent, FALSE, INFINITE);
EnterCriticalSection(&cs);
if(count>0){
cout << "OutputThread 2: " << arr[count] << endl;
arr[count]=0;
count--;
s[1]++;
}
LeaveCriticalSection(&cs);
SetEvent(hOEvent[1]);
}
return true;
}
DWORD OutputThread3(){
hTimerWait = WaitForSingleObject(hTimer, 100);
while(hTimerWait==WAIT_TIMEOUT){

WaitForMultipleObjects(2, hOEvent, FALSE, INFINITE);
EnterCriticalSection(&cs);
if(count>0){
cout << "OutputThread 3: " << arr[count] << endl;
arr[count]=0;
count--;
s[2]++;
}
LeaveCriticalSection(&cs);
SetEvent(hOEvent[2]);
}
return true;
}


int main(){
setlocale(LC_ALL, "Russian");

const int n = 3, //число прогонов
Time = 1, //время работы каждого прогона
nTimerUnitsPerSecond = 10000000;

int i, y;

count=0;

InitializeCriticalSection(&cs);
hTimer=CreateWaitableTimer(NULL, TRUE, NULL);
li = li-(Time * nTimerUnitsPerSecond);

hIEvent[0]=CreateEvent(NULL,TRUE,FALSE, NULL);
hIEvent[1]=CreateEvent(NULL,TRUE,FALSE, NULL);
hOEvent[0]=CreateEvent(NULL,TRUE,TRUE, NULL);
hOEvent[1]=CreateEvent(NULL,TRUE,TRUE, NULL);
hOEvent[2]=CreateEvent(NULL,TRUE,TRUE, NULL);

for(i=0; i<3; i++) s=0;

for(y=0; y<n; y++){
cout << "прогон №: " << y << endl;

ResetEvent(hIEvent[0]);
ResetEvent(hIEvent[1]);
SetEvent(hOEvent[0]);
SetEvent(hOEvent[1]);
SetEvent(hOEvent[2]);

SetWaitableTimer(hTimer, li, 0, NULL, NULL, FALSE);

hThread[0]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)InputThread1,NULL,CREATE_SUSPENDED,lpThreadId[0]);
if (hThread[0] == 0) LastErrorMessage( GetLastError() );
SetThreadPriority(hThread[0],THREAD_PRIORITY_BELOW_NORMAL);

hThread[1]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)InputThread2,NULL,CREATE_SUSPENDED,lpThreadId[1]);
if (hThread[1] == 0) LastErrorMessage( GetLastError() );
SetThreadPriority(hThread[1],THREAD_PRIORITY_BELOW_NORMAL);

ResumeThread(hThread[0]);
ResumeThread(hThread[1]);

hThread[2]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)OutputThread1,NULL,0,lpThreadId[2]);
if (hThread[2] == 0) LastErrorMessage( GetLastError() );

hThread[3]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)OutputThread2,NULL,0,lpThreadId[3]);
if (hThread[3] == 0) LastErrorMessage( GetLastError() );

hThread[4]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)OutputThread3,NULL,0,lpThreadId[4]);
if (hThread[4] == 0) LastErrorMessage( GetLastError() );

WaitForMultipleObjects(5,hThread,TRUE,INFINITE);

for(i=0; i<5; i++) CloseHandle(hThread[i]);
}

CloseHandle(hTimer);

for (i=0 ; i<2; i++)CloseHandle(hIEvent[i]);
for (i=0 ; i<3 ;i++) CloseHandle(hOEvent[i]);

DeleteCriticalSection(&cs);

cout << "Число обработанных сообщений: " <<endl;

cout << "OutputThread first " << s[0] << endl;
cout << "OutputThread second " << s[1] << endl;
cout << "OutputThread third " << s[2] << endl;

cout << "Кол-во исследований: " << n << endl;
cout << "Время исследования примерно: " << Time << " сек" << endl;

cout << "Cреднее число обработанных сообщений:" << endl;
cout << "OutputThread 1 " << s[0]/n << endl;
cout << "OutputThread 2 " << s[1]/n << endl;
cout << "OutputThread 3 " << s[2]/n << endl;

cin.get();
return 0;
}