信号量是CSemaphore的对象,该对象的作用是对访问某个共享资源的线程的数目进行控制。
CSemaphore类的构造函数原型如下:
CSemaphore(
LONG lInitialCount /* = 1 */, //计数器的初始值
LONG lMaxCount /* = 1 */, //计数器的最大计数值
LPCTSTR pstrName/* =NULL */, //信号的名称
LPSECURITY_ATTRIBUTES lpsaAttributes /* = NULL */ //指向一个SECURITY_ATTRIBUTES结构的指针
)
信号量对象中有一个可以设置初值的计数器,每当一个线程使用资源时,在该线程中就调用信号计数器对象的成员函数Lock()将该计数器的值减一,当计数器为0时,就不再允许其他线程访问该资源;而当一个线程使用信号量对象的成员函数Unlock()释放资源时,可以将计数器的值加一。因此,信号量对象允许多个线程访问同一个资源,但同时访问该资源的线程总数不能超过信号量对象的最大计数值。
示例:编写一个有四个线程的应用程序,理解信号量对象的使用。
1.创建单文档应用程序;
2.在视图类的实现文件定义一个信号量对象:
CSemaphore semaphoreObj(2,3);
3.在视图类的实现文件中定义四个线程函数:
UINT MessageThread1(LPVOID pParam)
{
semaphoreObj.Lock();
LPTSTR pMessage = _T("Thread1 is started");
CWnd *pMainWnd = AfxGetMainWnd();
::MessageBox(pMainWnd->m_hWnd, pMessage, _T("Thread messaeg"), MB_OK);
semaphoreObj.Unlock();
return 0;
}
UINT MessageThread2(LPVOID pParam)
{
semaphoreObj.Lock();
LPTSTR pMessage = _T("Thread2 is started");
CWnd *pMainWnd = AfxGetMainWnd();
::MessageBox(pMainWnd->m_hWnd, pMessage, _T("Thread messaeg"), MB_OK);
semaphoreObj.Unlock();
return 0;
}
UINT MessageThread3(LPVOID pParam)
{
semaphoreObj.Lock();
LPTSTR pMessage = _T("Thread3 is started");
CWnd *pMainWnd = AfxGetMainWnd();
::MessageBox(pMainWnd->m_hWnd, pMessage, _T("Thread messaeg"), MB_OK);
semaphoreObj.Unlock();
return 0;
}
UINT MessageThread4(LPVOID pParam)
{
semaphoreObj.Lock();
LPTSTR pMessage = _T("Thread4 is started");
CWnd *pMainWnd = AfxGetMainWnd();
::MessageBox(pMainWnd->m_hWnd, pMessage, _T("Thread messaeg"), MB_OK);
semaphoreObj.Unlock();
return 0;
}
4.在视图类的鼠标左键消息函数里面添加如下:
void CThreadTestView::OnLButtonDown(UINT nFlags, CPoint point)
{
AfxBeginThread(MessageThread1, _T("Thread is started"));
AfxBeginThread(MessageThread2, _T("Thread is started"));
AfxBeginThread(MessageThread3, _T("Thread is started"));
AfxBeginThread(MessageThread4, _T("Thread is started"));
CView::OnLButtonDown(nFlags, point);
}
程序运行结果如下: