现在的位置: 首页 > 自动控制 > 工业·编程 > 正文

多线程编程:信号量CSemaphore的使用

2013-07-27 23:31 工业·编程 ⁄ 共 1905字 ⁄ 字号 暂无评论

信号量是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); 
}

程序运行结果如下:

给我留言

留言无头像?