simple critical section

크리티컬 섹션 기본코드

typedef struct MSG_BLOCK_TAG {
	CRITICAL_SECTION mGuard;
	DWORD fReady, fStop; 
	volatile DWORD nCons, mSequence;
	DWORD nLost;
	time_t mTimestamp;
	DWORD mChecksum;
	DWORD mData[DATA_SIZE];
} MSG_BLOCK;

DWORD WINAPI Produce (void *arg)
{
	srand ((DWORD)time(NULL));	
	while (!mBlock.fStop) {
		
		Sleep(rand()/100);
		
		EnterCriticalSection (&mBlock.mGuard);
		__try {
			if (!mBlock.fStop) {
				mBlock.fReady = 0;
				MessageFill (&mBlock);
				mBlock.fReady = 1;
				InterlockedIncrement (&mBlock.mSequence);
			}
		} 
		__finally { LeaveCriticalSection (&mBlock.mGuard); }
	}
	return 0;
}

DWORD WINAPI Consume (void *arg)
{
	CHAR command, extra;

	while (!mBlock.fStop) { 
		_tprintf (_T("\n**Enter 'c' for Consume; 's' to stop: "));
		_tscanf (_T("%c%c"), &command, &extra);
		if (command == _T('s')) {
			mBlock.fStop = 1;
		} else if (command == _T('c')) { 
			EnterCriticalSection (&mBlock.mGuard);
			__try {
				if (mBlock.fReady == 0) 
					_tprintf (_T("No new messages. Try again later\n"));
				else {
					MessageDisplay (&mBlock);
					mBlock.nLost = mBlock.mSequence - mBlock.nCons + 1;
					mBlock.fReady = 0;
					InterlockedIncrement(&mBlock.nCons);
				}
			} 
			__finally { LeaveCriticalSection (&mBlock.mGuard); }
		} else {
			_tprintf (_T("Illegal command. Try again.\n"));
		}
	}
	return 0;		
}