VC++线程同步(五) 信号量使用例子

2024-12-24 技术教程

信号量(Semaphore)

信号量是内核对象,使用几个形象的例子,进行描述.

1 假设有5个位置,而外面有很多人要进来,那么当5个位置被人占用了

后,其他人就必须排队等待,每个人使用时间不同,5个占用的位置,其中有两个完成了,那么,排队的人中,最前面的两个人进行可以使用,但是最多就是5个人同时能够使用,这就是信号量.

2 例如我们在服务器中创建了一个线程池,它由5个线程组成,也就意味着,最多同时处理5个请求,一旦超过5个,那么请求就放入缓冲中,当一个或多个请求(最多5个)完成后,那么从缓冲中拿出其他的请求进行处理.

信号量的特点:

1 信号量同来对资源进行计数

2 包含一个使用计数器,一个最大资源计数器,和一个当前资源计数器

3 最大资源计数器用来控制最大的子元素

4 当前资源计数器表示当前可用的资源数量

触发规则和当前资源计数器是相关的。

触发规则:

1 如果当前资源>0则信号量处于触发状态

2 如果当前资源=0,则信号量处于未触发状态

3 系统绝对不会让当前资源技术变为负值

4 当前资源计数绝对不会大于最大资源计数

运行流程:

1 假设我们创建了一个信号量,它的最大资源计数为5,且当前资源计数

也为5(一般都是在初始化过程中间最大的资源计数值和当前资源计数值是相同的) 由于当前资源计数器大于0,说明信号量处于触发状态.

2 为了获取对被保护的资源的访问权,线程会调用wait函数,并转入信号量的句柄,在内部,等待函数会检测当前资源计数器技术,如果大于

0(大于0触发状态)那么等待函数会将当前资源计数器减1并让调用线程

继续运行,如果等于0(未触发状态)那么系统会让线程进入等待状态(不消化cpu)，当另外一个线程将信号量的当前资源计数递增时,系统会

记得哪些线程在等待,使他们编程可调度状态(并相应的递减当前资源计数)

3 线程通过releaseSemaphore来递增信号量的当前资源计数器.

来看代码:

全局变量 HANDLE g_hSem;

创建一个信号量CreateSemaphore(NULL,2,2,NULL);

参数1 windows。。权限

参数2 代表当前资源计数值

参数3 最大资源计数器,表示信号量同时可以管理2个线程

参数4 对象名...

应为创建的时候,当前的资源计数大于0,所以他是触发状态的。

创建5个线程,用5个线程竞争两个位置,体现一下竞争的激烈.

caseWM_CREATE:{//系统中基于对话框字体的高度intcyChar=HIWORD(GetDialogBaseUnits());thrParams4.hwnd=hWnd;thrParams4.cyChar=cyChar;//创建信号量g_hSem=CreateSemaphore(NULL,2,2,NULL);HANDLEhandleEmployee1=CreateThread(NULL,0,ThrEmployeeProc1,&thrParams4,0,NULL);HANDLEhandleEmployee2=CreateThread(NULL,0,ThrEmployeeProc2,&thrParams4,0,NULL);HANDLEhandleEmployee3=CreateThread(NULL,0,ThrEmployeeProc3,&thrParams4,0,NULL);HANDLEhandleEmployee4=CreateThread(NULL,0,ThrEmployeeProc4,&thrParams4,0,NULL);HANDLEhandleEmployee5=CreateThread(NULL,0,ThrEmployeeProc5,&thrParams4,0,NULL);//关闭线程句柄CloseHandle(handleEmployee1);CloseHandle(handleEmployee2);CloseHandle(handleEmployee3);CloseHandle(handleEmployee4);CloseHandle(handleEmployee5);}caseWM_DESTROY://关闭信号量CloseHandle(g_hSem);PostQuitMessage(0);break;

来看一下线程函数吧.

DWORDWINAPIThrEmployeeProc1(LPVOIDlp){PPARAMSparam4=static_cast<PPARAMS>(lp);//等待这个信号量永远阻塞如果信号量的当前资源计数大于0就触发反悔WaitForSingleObject(g_hSem,INFINITE);//当他返回的时候当前资源计数会减1//休眠2秒Sleep(2000);//获取当前毫秒数DWORDdwCurTime=GetTickCount();//获得DCHDChdc=GetDC(param4->hwnd);//显示文本BOOLbF=TextOut(hdc,0,(g_iLine4++)*param4->cyChar,_T("员工线程1正在使用公司上网"),lstrlen(_T("员工线程1正在使用公司上网")));//释放dcReleaseDC(param4->hwnd,hdc);//循环10秒退出while(true){if((GetTickCount()-dwCurTime)>1000*10){HDChdc=GetDC(param4->hwnd);SetTextColor(hdc,RGB(255,0,0));TextOut(hdc,0,(g_iLine4++)*param4->cyChar,_T("员工线程1已经没有使用公司上网"),lstrlen(_T("员工线程1已经没有使用公司上网")));ReleaseDC(param4->hwnd,hdc);break;}Sleep(1000);}//释放信号量信号量句柄穿进去并且//1代表加1当前资源计数器+1可以+2+3但是现在加1最合适//最后一个参数是反回上一次资源计数器的数量大部分情况下不需要这个东西ReleaseSemaphore(g_hSem,1,NULL);return0;}

效果：

我们发现这个上网的数量,是通过信号量被控制住了,每次最多

可以有两个员工可以上网。

有不懂的连续我qq：2438746951

交流群:140066160

源代码地址:http://down.51cto.com/data/2329794