zoukankan      html  css  js  c++  java
  • [一个经典的多线程同步问题]解决方案四:信号量

    本篇文章介绍如何使用信号量解决线程的同步互斥。

    首先也来看看如何使用信号量,信号量Semaphore常用有三个函数,使用很方便。下面是这几个函数的原型和使用说明。

    第一个 CreateSemaphore
    函数功能:创建信号量
    函数原型:
    HANDLE CreateSemaphore(
      LPSECURITY_ATTRIBUTES lpSemaphoreAttributes,
      LONG lInitialCount,
      LONG lMaximumCount,
      LPCTSTR lpName
    );
    函数说明:
    第一个参数表示安全控制,一般直接传入NULL。
    第二个参数表示初始资源数量。
    第三个参数表示最大并发数量。
    第四个参数表示信号量的名称,传入NULL表示匿名信号量。
    
    第二个 OpenSemaphore
    函数功能:打开信号量
    函数原型:
    HANDLE OpenSemaphore(
      DWORD dwDesiredAccess,
      BOOL bInheritHandle,
      LPCTSTR lpName
    );
    函数说明:
    第一个参数表示访问权限,对一般传入SEMAPHORE_ALL_ACCESS。详细解释可以查看MSDN文档。
    第二个参数表示信号量句柄继承性,一般传入TRUE即可。
    第三个参数表示名称,不同进程中的各线程可以通过名称来确保它们访问同一个信号量。
    
    第三个 ReleaseSemaphore
    函数功能:递增信号量的当前资源计数
    函数原型:
    BOOL ReleaseSemaphore(
      HANDLE hSemaphore,
      LONG lReleaseCount,  
      LPLONG lpPreviousCount 
    );
    函数说明:
    第一个参数是信号量的句柄。
    第二个参数表示增加个数,必须大于0且不超过最大资源数量。
    第三个参数可以用来传出先前的资源计数,设为NULL表示不需要传出。
    

    注意:当前资源数量大于0,表示信号量处于触发,等于0表示资源已经耗尽故信号量处于末触发。在对信号量调用等待函数时,等待函数会检查信号量的当前资源计数,如果大于0(即信号量处于触发状态),减1后返回让调用线程继续执行。一个线程可以多次调用等待函数来减小信号量。 

    最后一个 信号量的清理与销毁
    由于信号量是内核对象,因此使用CloseHandle()就可以完成清理与销毁了。
    

    还是之前的那个线程同步互斥的问题,代码实现:

    #include <stdio.h>
    #include <process.h>
    #include <windows.h>
    
    int g_num;
    const int THREAD_NUM = 10;
    //信号量和关键段
    HANDLE g_hThreadParam;
    CRITICAL_SECTION g_csThreadCode;
    
    unsigned int __stdcall Fun(void *param)
    {
    	int n_thread_id = *(int *)param;
    	ReleaseSemaphore(g_hThreadParam, 1, NULL);//释放一个资源,信号量增加
    
    	Sleep(50);
    
    	EnterCriticalSection(&g_csThreadCode);
    	g_num++;
    	printf("线程编号为%d 全局资源值为%d
    ", n_thread_id, g_num);
    	LeaveCriticalSection(&g_csThreadCode);
    
    	return 0;
    }
    
    int main(void)
    {
    	//初始化信号量、关键段
    	g_hThreadParam = CreateSemaphore(NULL, 0, 1, NULL);//当前资源为0,最大允许1个线程访问
    	InitializeCriticalSection(&g_csThreadCode);
    
    	g_num = 0;
    	HANDLE handle[THREAD_NUM];
    	int i = 0;
    	while(i < THREAD_NUM)
    	{
    		handle[i] = (HANDLE)_beginthreadex(NULL, 0, Fun, &i, 0, NULL);
    
    		WaitForSingleObject(g_hThreadParam, INFINITE);
    		i++;
    	}
    
    	WaitForMultipleObjects(THREAD_NUM, handle, true, INFINITE);
    
    	DeleteCriticalSection(&g_csThreadCode);
    	CloseHandle(g_hThreadParam);
    	for (i = 0; i < THREAD_NUM; i++)
    	{
    		CloseHandle(handle[i]);
    	}
    	return 0;
    }
    

    运行结果图:

    可以看出来,信号量也可以解决线程之间的同步问题。

    由于信号量可以计算资源当前剩余量并根据当前剩余量与零比较来决定信号量是处于触发状态或是未触发状态,因此信号量的应用范围相当广泛。

  • 相关阅读:
    08.Python网络爬虫之图片懒加载技术、selenium和PhantomJS
    07.验证码处理
    Python网络爬虫第三弹《爬取get请求的页面数据》
    设计模式【十】—— 访问者模式
    设计模式【九】—— 模板方法模式/命令模式
    设计模式【八】—— 代理模式
    设计模式【七】—— 外观模式/享元模式
    设计模式【六】—— 装饰者模式/组合模式
    设计模式【五】—— 适配器模式/桥接模式
    设计模式【四】—— 建造者模式
  • 原文地址:https://www.cnblogs.com/stemon/p/4855829.html
Copyright © 2011-2022 走看看