用vc实现生产者消费者问题

用vc实现生产者消费者问题(2) //////////////////////////////////////////////////////////
CProducerThread::CProducerThread(void* hParent)
:m_pParentDlg(hParent)
{
}

int CProducerThread::Run()
{
 CP_CDlg *pDlg;
 pDlg=(CP_CDlg*)m_pParentDlg;
 CSingleLock mutexLock(pDlg->m_pMutex);

 for(int i=0;i<MAX_DATA_COUNT;i++)
 {
  pDlg->m_pSemaphoreEmpty->Lock();
   mutexLock.Lock();
    pDlg->m_sBuf.Format("%0.10d",i);   
   mutexLock.Unlock();
  pDlg->m_pSemaphoreFull->Unlock(); 
 }

 return CWinThread::Run();
}
CConsumerThread::CConsumerThread(void *pParent)
:m_pParent(pParent)
{

}
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();
}
//////////////////////////////////////////////////////////
3启动线程：
//////////////////////////////////////////////////////////
 m_pSemaphoreFull =new CSemaphore(1,1);
 m_pSemaphoreEmpty =new CSemaphore(0,1);