consumerthread.cpp

此文件用于实现生产者消费者的问题

/************************************************************************
* 版权所有 (C)2003,windcao(曹建峰)
* 作    者： 曹建峰
* 完成日期： 2004年1月9日
* 修改日期    版本号     修改人	     修改内容
************************************************************************/
// ConsumerThread.cpp : implementation file
//

#include "stdafx.h"
#include "P_C.h"
#include "ConsumerThread.h"
#include "P_CDlg.h"
#include <afxmt.h>
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif

/////////////////////////////////////////////////////////////////////////////
// CConsumerThread

IMPLEMENT_DYNCREATE(CConsumerThread, CWinThread)

CConsumerThread::CConsumerThread()
{
}
CConsumerThread::CConsumerThread(void *pParent):m_pParent(pParent)
{

}
CConsumerThread::~CConsumerThread()
{
}

BOOL CConsumerThread::InitInstance()
{
	// TODO:  perform and per-thread initialization here
	return TRUE;
}

int CConsumerThread::ExitInstance()
{
	// TODO:  perform any per-thread cleanup here
	return CWinThread::ExitInstance();
}

BEGIN_MESSAGE_MAP(CConsumerThread, CWinThread)
	//{{AFX_MSG_MAP(CConsumerThread)
		// NOTE - the ClassWizard will add and remove mapping macros here.
	//}}AFX_MSG_MAP
END_MESSAGE_MAP()

/////////////////////////////////////////////////////////////////////////////
// CConsumerThread message handlers

int CConsumerThread::Run() 
{
	CP_CDlg *pDlg;
	pDlg=(CP_CDlg*)this->m_pParent; 
	char*pBuf;
	pBuf=this->m_Data;
	bool bSleep;
	for(int i=0;i<MAX_DATA_COUNT;i+=10)
	{
		pDlg->m_pSemaphoreFull->Lock();
			pDlg->m_pMutex->Lock();
				sprintf(pBuf,pDlg->m_sBuf);
				bSleep=pDlg->m_bSlow ;
			pDlg->m_pMutex->Unlock();				
				pBuf+=10;
				if(pBuf>m_Data+CSM_BUF_COUNT-10)
					pBuf=m_Data;
				m_Data[CSM_BUF_COUNT]=0;
			pDlg->m_pMutex->Lock();
				sprintf(pDlg->m_sBufCSM.GetBuffer(CSM_BUF_COUNT+10),m_Data);
			pDlg->m_pMutex->Unlock();
			if (bSleep)
				Sleep(100);
		pDlg->m_pSemaphoreEmpty ->Unlock();
	}
	

	return CWinThread::Run();
}