VPF::[C++] Объекты синхронизации WIN32 - Форум программистов

zall

Дата 10.4.2011, 12:19 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 90
Регистрация: 18.12.2008

Репутация: нет
Всего: нет

Организовать совместное использование мьютекса и события для защиты добавления элемента в очереди. Очередь произвольного формата. Событие сигнализирует чтение из очереди, а мьютекс - запись. Требуется снять статистику по времени использования объектов ядра.

Собственно вот до чего удалось дойти, а дальше как-то путные мысли в голову не идут...

и ещё поправьте меня если что, результат же по идее должен получаться сначала первое число из массива,потом первое и второе, дальше первое второе третье ну и т.д?

конечно есть и индусский код, но как могу.

Код


#include "stdafx.h"
#include <windows.h>
#include <conio.h>
#include <stdio.h>
#include <iostream>

using namespace std;

const int N=10;
DWORD WINAPI Proc1(LPVOID);
DWORD WINAPI Proc2(LPVOID);
int i = 0;
int tmp = 0;
int y = 3;
int m[] = {0,0,0,0,0,0,0,0,0,0};
HANDLE h1,h2,eve,mtx;
void main()
{
    
    HANDLE h[2];
    eve = CreateEvent(NULL, true, false, NULL);    
    h[0] = CreateThread(NULL,0,&Proc1,NULL,0,0);
    h[1] = CreateThread(NULL,0,&Proc2,NULL,0,0);
    WaitForMultipleObjects(2,h,true,INFINITE);
    CloseHandle(h[0]);
    CloseHandle(h[1]);
    CloseHandle(eve);
    CloseHandle(mtx);
    _getch();
}

DWORD WINAPI Proc1( LPVOID lpParam ) 
{    
    cout<<("write")<<('\n');
    for ( i = tmp; i < N; i++) 
    {    
        tmp = i;
        mtx = CreateMutex(NULL, false, NULL);
        WaitForSingleObject(eve,INFINITE);
        OpenMutex(NULL, true, NULL);        
        m[i] = y*i;
        ResetEvent(eve);
        ReleaseMutex(mtx);
    }
    return 0;
}
DWORD WINAPI Proc2( LPVOID lpParam ) 
{
    cout<<("watch")<<('\n');
    WaitForSingleObject(mtx,INFINITE);
    for ( int j = 0; j < tmp+10; j++) 
    {
        
        cout<<i<<(" = ")<<m[j]<<(" ");
        SetEvent(eve);
    }
    cout<<('\n');
    return 0;
}

t_gran

Дата 11.4.2011, 10:52 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 621
Регистрация: 13.11.2007
Где: г.Усть-Илимск

Репутация: 33
Всего: 37

zall, т.е. так?:

Код


#include <windows.h>
#include <stdbool.h>
#include <stdio.h>
#include <conio.h>

typedef struct _TList
{
   int *arr;
   int size;
}  TList;

HANDLE eve, mtx;

//----------------------------------------------//
DWORD WINAPI Writer(TList *param) 
{
   int i;
   
   for (i = 0; i < param->size; ++i)
   {
      WaitForSingleObject(eve, INFINITE);
      OpenMutex(0, true, NULL);

      param->arr[i] = i+1;
      Sleep(100);
        
      ResetEvent(eve);
      ReleaseMutex(mtx);
   }
   
   return 0;
}
//----------------------------------------------//
DWORD WINAPI Reader(TList *param) 
{
   int i;
   
   for (i = 0; i < param->size; ++i)
   {
      int j = 0;

      WaitForSingleObject(mtx, INFINITE);
      while ((param->arr[j] != 0) && (j < param->size))
      {
         printf("%d ", param->arr[j]);
         j++;
      }
      Sleep(200);
      SetEvent(eve);
      printf("\n");
   }
   return 0;
}
//----------------------------------------------//

int main(int argc, char **argv)
{
   int arr[] = {0,0,0,0,0,0,0,0,0,0};
   int size = sizeof(arr) / sizeof(*arr);

   TList lst = {arr, size};
   
   eve = CreateEvent(NULL, true, false, NULL);    
   mtx = CreateMutex(NULL, false, NULL);

   CreateThread(NULL, 0, LPTHREAD_START_ROUTINE(&Writer), &lst, 0, 0);
   CreateThread(NULL, 0, LPTHREAD_START_ROUTINE(&Reader), &lst, 0, 0);

   _getch();
   
   CloseHandle(eve);
   CloseHandle(mtx);
 
   return 0;
}

--------------------

Я знаю, что ничего не знаю© Сократ
user posted image

zall

Дата 11.4.2011, 21:55 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 90
Регистрация: 18.12.2008

Репутация: нет
Всего: нет

огромное спасибо всё как надо

Это сообщение отредактировал(а) zall - 11.4.2011, 23:17

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Центр помощи \| Следующая тема »