使用信号量 进行windows线程同步 (Semaphore)

信号量类似于事件,采用通知的方式是两个线程彼此同步,信号量是一个整数,信号量是通过减的方式来操作的,每使用WaitForSingleObjecst等候一次,信号量减一,等到信号量为0时,线程阻塞.ReleaseSemaphore负责释放信号量,信号量的操作就是加减操作,通过判断是否够减来决定是否阻塞.下边是用到的函数:

HANDLE CreateSemaphore(  //创建信号量
  LPSECURITY_ATTRIBUTES lpSemaphoreAttributes, // SD    信号量安全属性,一般内核对象都会具有此数据结构
  LONG lInitialCount,                          // initial count  //初始化信号量的大小
  LONG lMaximumCount,                          // maximum count  //信号量最大值,
  LPCTSTR lpName                               // object name   //信号量的名称(内核对象名称,跨进程访问使用,此处匿名)
);

DWORD WaitForSingleObject(  //等候任何可等候的内核对象
  HANDLE hHandle,        // handle to object    //内核对象句柄(此句柄只是进程内有效)
  DWORD dwMilliseconds   // time-out interval     //  等候的超时时间
);

BOOL ReleaseSemaphore(  //释放信号量
  HANDLE hSemaphore,       // handle to semaphore   信号量句柄
  LONG lReleaseCount,      // count increment amount  信号量数量(要操作的数量)   如果大于初始化信号量的最大值,则函数执行失败,信号量不做改变.
  LPLONG lpPreviousCount   // previous count   在操作执行之前,信号量的数量
);

下边是一个使用信号量进行线程同步的小例子.此处使用匿名内核对象,由于是同一个进程中的线程,所以不需要跨进程.

// Semaphore.cpp : 定义控制台应用程序的入口点。
#include "stdafx.h"
#include <Windows.h>

HANDLE g_hSemp=NULL;
DWORD WINAPI ThreadProc1(LPVOID pVoid);
DWORD WINAPI ThreadProc2(LPVOID pVoid);

//信号量的操作方式是根据加减和是否够减来决定是否阻塞,只要大于0.
int _tmain(int argc, _TCHAR* argv[])
{
g_hSemp=CreateSemaphore(NULL/*此处采用默认值,所以为NULL*/,1,10,NULL);
DWORD nThreadID=0;
HANDLE hThread[2]={0};
hThread[0]=CreateThread(NULL,0,ThreadProc1,NULL,0,&nThreadID);
hThread[1]=CreateThread(NULL,0,ThreadProc2,NULL,0,&nThreadID);
//等待线程结束返回
WaitForMultipleObjects(2,hThread,TRUE,INFINITE);
//关闭内核对象
CloseHandle(hThread[0]);
CloseHandle(hThread[1]);
CloseHandle(g_hSemp);
return 0;
}

DWORD WINAPI ThreadProc1( LPVOID pVoid )
{
while(1)
{
//初始化信号量为1,此处等待执行后,为0,线程二无法获得,只能阻塞
WaitForSingleObject(g_hSemp,INFINITE);
printf("我是线程1,我执行一下-------\n");
Sleep(1000);//使线程放下当前剩余的时间片
//此函数将信号量+1,信号量变为1之后,这时候线程一又开始wait,但是根据谁先等待谁先获得,那么这时候线程二将获取到执行权,执行完之后,又会释放信号量
//从而实现,线程1执行一次,线程二执行一次,彼此轮询.
ReleaseSemaphore(g_hSemp,1,NULL);
}
return 0;
}

DWORD WINAPI ThreadProc2( LPVOID pVoid )
{
while(1)
{
WaitForSingleObject(g_hSemp,INFINITE);
printf("我是线程2,我也要执行一下=======\n");
Sleep(1000);//使线程放下当前剩余的时间片
ReleaseSemaphore(g_hSemp,1,NULL);
}
return 0;
}