CreateSemaphore是Declare Function CreateSemaphore Lib kernel32 Alias CreateSemaphoreA (lpSemaphoreAttributes AsSECURITY_ATTRIBUTES, ByVal lInitialCount As Long, ByVal lMaximumCount As Long, ByVal lpName As String) As Long。
CreateSemaphore是Declare Function CreateSemaphore Lib kernel32 Alias CreateSemaphoreA (lpSemaphoreAttributes AsSECURITY_ATTRIBUTES, ByVal lInitialCount As Long, ByVal lMaximumCount As Long, ByVal lpName As String) As Long。
HANDLE CreateSemaphore( LPSECURITY_ATTRIBUTES lpSemaphoreAttributes, // SD LONG lInitialCount, // initial count LONG lMaximumCount, // maximum count LPCT STRlpName// object name);
创建一个新的信号量
Long，如执行成功，返回信号量对象的句柄；零表示出错。会设置GetLastError。即使返回一个有效的句柄，但倘若它指出同名的一个信号量已经存在，那么GetLastError也会返回ERROR_ALREADY_EXISTS
lpSemaphoreAttributes SECURITY_ATTRIBUTES，指定一个SECURITY_ATTRIBUTES结构，或传递零值（将参数声明为ByVal As Long，并传递零值）——表示采用不允许继承的默认描述符。该参数定义了信号量的安全特性
lInitialCount Long，设置信号量的初始计数。可设置零到lMaximumCount之间的一个值
lMaximumCount Long，设置信号量的最大计数
lpName String，指定信号量对象的名称。用vbNullString可创建一个未命名的信号量对象。如果已经存在拥有这个名字的一个信号量，就直接打开现成的信号量。这个名字可能不与一个现有的互斥体、事件、可等待计时器或文件映射的名称相符
一旦不再需要，一定记住用CloseHandle关闭信号量的句柄。它的所有句柄都关闭以后，对象自己也会删除
一旦值大于零，信号量就会触发（发出信号）。ReleaseSemaphore函数的作用是增加信号量的计数。如果成功，就调用信号量上的一个等待函数来减少它的计数
Semaphore是另一个同步问题机制，不论是Event或Mutex，其他Process在执行WaitForSingleObject时，就看当时的对象是Signal或UnSignal而决定是否等待，而Semaphore也相同，但是它要变成Signal /UnSignal的状态，却有些不同，它是提供一个计数值，它允许在这个计数值之内，任何执行到WaitForSingleObject的Thread都不会停下来，而且每执行WaitForSingleObject一次，计数值就减一，当计数值变成0时，该Semaphore才会处於UnSignal的状态，而某个Thread ReleaseSemaphore时，便会将计数值增加，以便其他的Thread或本身可得Signal的讯号，而使WaitForSingleObject停止等待。
例如说，该电脑只有两个 COM PORT，所以只允许两个计数值同时使用COM PORT，因此，
hSema = CreateSemaphore(ByVal 0&, 2, 2, "MySema")
第2个参数表示：刚开始的时候，有多少个COM PORT可使用
第3个参数表示：最多有多少个COM PORT可使用
第4个参数:Semaphore的名称，只要名称相同，则传回的handle(hSema)会指向相同的Semaphore对象。
因此，要使用相同的名称来Create Semaphore才能达共用一个Semaphore的效果。而使用
WaitForSingleObject来Check看看是否还有剩下的COM Port可使用，如果还有剩(计数值 > 0)，则没有
等待而可执行下一行指令，同时，计数值减1。若有第三个要求COM PORT的使用，那它就得等待，直到
有Thread执行ReleaseSemaphore(hSema, 1, count)
第2个参数表示：Release多少个COM PORT出来，一般来说都是1，表示一个ReleaseSemaphore
会将计数器的值加一，但是您也可以指定 > 1的值，代表一口气增加计数器的值( + n , n > 1)。例如，您的程式一口气使用了两个COM PORT，并假设您於程式中有使用WaitForSingleObject两次，程式最後，使用
ReleaseSemaphore(hSema, 2, count)而不必
ReleaseSemaphore(hSema, 1, count)执行两次。
第3个参数表示：ReleaseSemaphore执行之前计数器原来的值。
Semaphore和Event有个地方相同，那就是没有Owner的观念，即Thread A 所Create出的
Semaphore对象，於Thread B中执行ReleaseSemaphore时，依然会增加计数器的值
示例：
write线程写了之后，read1,read2,read3才能读，且只有3个线程都读完，write函数才能向buffer中写。
下面是具体代码：
#include<windows.h>#include<process.h>#include<iostream>using namespace std;CRITICAL_SECTION cs;typedef struct{ HANDLE h1; HANDLE h2; HANDLE h3; HANDLE h4; int a;}PARAMS,*PPARAMS;void read1(PVOID pvoid){ while(TRUE){ volatile PPARAMS pparams=(PPARAMS)pvoid; WaitForSingleObject(pparams->h2,INFINITE); EnterCriticalSection(&cs); cout<<"读线程1开始读取...n"; cout<<(pparams->a)<<endl; LeaveCriticalSection(&cs); Sleep(1000); ReleaseSemaphore(pparams->h1,1,NULL); }}void read2(PVOID pvoid){ while(TRUE){ volatile PPARAMS pparams=(PPARAMS)pvoid; WaitForSingleObject(pparams->h3,INFINITE); EnterCriticalSection(&cs); cout<<"读线程2开始读取...n"; cout<<(pparams->a)<<endl; LeaveCriticalSection(&cs); Sleep(1000); ReleaseSemaphore(pparams->h1,1,NULL); }}void read3(PVOID pvoid){ while(TRUE){ volatile PPARAMS pparams=(PPARAMS)pvoid; WaitForSingleObject(pparams->h4,INFINITE); EnterCriticalSection(&cs); cout<<"读线程3开始读取...n"; cout<<(pparams->a)<<endl; LeaveCriticalSection(&cs); Sleep(1000); ReleaseSemaphore(pparams->h1,1,NULL); }}void write(PVOID pvoid){ while(TRUE){ volatile PPARAMS pparams=(PPARAMS)pvoid; WaitForSingleObject(pparams->h1,INFINITE); WaitForSingleObject(pparams->h1,INFINITE); WaitForSingleObject(pparams->h1,INFINITE); cout<<"=================n"; cout<<"写线程开始写入...n"; pparams->a=rand()%256; cout<<"写入"<<(pparams->a)<<endl; ReleaseSemaphore(pparams->h2,1,NULL); ReleaseSemaphore(pparams->h3,1,NULL); ReleaseSemaphore(pparams->h4,1,NULL); }}int main(){ PARAMS params; params.h1=CreateSemaphore(NULL,3,3,NULL); params.h2=CreateSemaphore(NULL,0,1,NULL); params.h3=CreateSemaphore(NULL,0,1,NULL); params.h4=CreateSemaphore(NULL,0,1,NULL); InitializeCriticalSection(&cs); _beginthread(read1,0,¶ms); _beginthread(read2,0,¶ms); _beginthread(read3,0,¶ms); _beginthread(write,0,¶ms); //HANDLEhEvent; //hEvent=CreateEvent(NULL,FALSE,FALSE,NULL); //WaitForSingleObject(hEvent,INFINITE); int a;cin>>a; DeleteCriticalSection(&cs); return 0;}
温馨提示：