很多情況下我們需要多個線程互相協助，來完成同一個任務。但是線程很難從外部進行控制。
利用線程同步技術可以使線程彼此交互，從而避免了外部控制對與時間和資源的浪費。
在實際工作過程中我就遇到了類似的問題，需要對共享的緩沖區進行操作。
有插入的線程也有讀取的線程，這使我忽然想到了生產者和消費者。我從MSDN 找到csdn 使用了各式各樣的搜索引擎，只找到了很有現的關於CSemaphore的資料。
////////////////////////////////////
// 生產者消費者問題
////////////////////////////////////
生產者要不斷將數據放入共享的緩沖，消費者要不斷從緩沖取出數據。消費者必須等生產者
取走數據後才能再放新數據(不覆蓋數據)，消費者必須等生產者放入新數據後才能去取(不重復)。
/////////////////////////////////////
// 使用信號量的方法
/////////////////////////////////////
當線程使用指定數量的共享資源時，首先調用信號量的lock方法"我能用資源嗎"。當有的空閒
共享資源時(此時計數器值>0)線程繼續執行並且減少計數器的數量告訴其他線程"我用了××個資
源"。否則掛起自己直到有足夠的可用的資源為止。當使用完資源時線程調用unlock方法告訴其他
線程"我已經不用該資源了"。
/////////////////////////////////////
// 實現
////////////////////////////////////
///////////////////////////////////
1創建一個基於對話框的程序。添加如下成員。
//////////////////////////////////
bool m_bSlow;//緩慢顯示線程進行的結果
CProducerThread *m_pProducerThread;//生產者線程
CConsumerThread *m_pConsumerThread;//消費者線程
CSemaphore* m_pSemaphoreEmpty;//緩沖空的標志
CSemaphore* m_pSemaphoreFull;//緩沖滿的標志
CMutex *m_pMutex;//互斥信號量
添加兩編輯框用類向導，相關的添加成員
CString m_sBufCSM;//用來顯示消費者取到的數據
CString m_sBuf;//顯示生產者插入緩沖的數據
/////////////////////////////////////////////
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);
m_pMutex =new CMutex;
this->m_bUpdateAuto =false;
this->m_pProducerThread =new CProducerThread(this);
this->m_pConsumerThread =new CConsumerThread(this);
this->m_sBuf.Format("1234567890");
this->UpdateData(false);
this->m_pProducerThread->CreateThread(CREATE_SUSPENDED);
VERIFY(m_pProducerThread->SetThreadPriority(THREAD_PRIORITY_IDLE));
this->m_pConsumerThread->CreateThread(CREATE_SUSPENDED);
VERIFY(m_pConsumerThread->SetThreadPriority(THREAD_PRIORITY_IDLE));
this->m_pProducerThread->ResumeThread();
this->m_pConsumerThread->ResumeThread();
