C / C++ / MFC

<br />
//---------------------------------<br />
//  Buffer.c<br />
//---------------------------------<br />
#include "buffer.h"<br />
#include <windows.h><br />
#include "screen.h"<br />
HANDLE NFull, NEmpty;<br />
HANDLE mutexProTime, mutexConTime;<br />
int sleepTimePro = 100; //sleeping interval for sleep function of producer<br />
int sleepTimeCon = 200;//sleeping interval for sleeping function of consumer<br />
<br />
void Buffer::BufInit(void)<br />
{<br />
 bufferSize = 8; <br />
 NxtIn = 0;<br />
 NxtOut = 0;<br />
 NFull = CreateSemaphore(NULL, 0, bufferSize, 0);<br />
 NEmpty = CreateSemaphore(0, bufferSize, bufferSize, 0);<br />
 mutexProTime = CreateMutex(NULL, TRUE, 0);<br />
 mutexConTime = CreateMutex(NULL, TRUE, NULL);<br />
  proTime = proWaitTime = 0; //producing time and wait time<br />
  conTime= conWaitTime = 0;// initialise consumer consume time and consumer wait time<br />
 <br />
}<br />
void Buffer::BufPut(char c)<br />
{<br />
  <br />
  if(WaitForSingleObject(NEmpty, 10) != WAIT_OBJECT_0)<br />
   proWaitTime += 100;<br />
  <br />
  buffer[NxtIn] = c;<br />
  NxtIn = (NxtIn+1) % bufferSize;<br />
  if (NxtIn == 0)<br />
  {<br />
 scrWriteAt(0, 5, "                       ");<br />
 scrWriteAt(0, 5, "Producer is waiting");<br />
  }<br />
  else<br />
  {<br />
 scrWriteAt(0, 5, "                       ");<br />
 scrWriteAt(0, 5, "Producer is generating ");<br />
  }<br />
  ReleaseSemaphore(NFull, 1, 0);<br />
  Sleep(sleepTimePro);<br />
 <br />
  proTime += sleepTimePro;<br />
  <br />
 <br />
}<br />
char Buffer::BufGet(void)<br />
{ <br />
 char s;  <br />
 if(WaitForSingleObject(NFull, 10) != WAIT_OBJECT_0)<br />
  conWaitTime += 100;<br />
 s = buffer[NxtOut];<br />
 NxtOut = (NxtOut+1) % bufferSize;<br />
 <br />
 if (NxtOut == 0)<br />
 {<br />
  scrWriteAt(0, 7, "                              ");<br />
  scrWriteAt(0,7,"Consumer is waiting  " );<br />
 }<br />
 else<br />
 {<br />
  scrWriteAt(0, 7, "                              ");<br />
  scrWriteAt(0, 7, "Consumer is consuming  ");<br />
 }<br />
 ReleaseSemaphore(NEmpty, 1, 0);<br />
 Sleep(sleepTimeCon);<br />
 conTime += sleepTimeCon;<br />
 return s;<br />
 <br />
}<br />
long Buffer::TimeProducerProduces()<br />
{<br />
 <br />
 <br />
 return proTime;<br />
}<br />
long Buffer::TimeProducerWaits()<br />
{<br />
 return proWaitTime;<br />
}<br />
long Buffer::TimeConsumerConsumes()<br />
{<br />
 return conTime;<br />
}<br />
long Buffer::TimeConsumerWaits()<br />
{<br />
 return conWaitTime;<br />
}<br />