Saturday, May 18, 2013

使用信号灯同步线程

#include <windows.h> 
#include <process.h>  // _beginthread, _endthread 
#include <stdio.h> 
 
/*
 * 可以理解信号灯内部有N个灯泡。
 * 如果有一个灯泡亮着,就代表信号灯处于激发状态,如果全灭,则代表信号灯处于未激发状态。
 */ 
 
// 创建线程 
UINT WINAPI Thread1(LPVOID para) 

    printf("进入Thread1......\n"); 
    HANDLE* phSemaphore = (HANDLE*)para; 
 
    printf("将等待5秒......\n"); 
    // 等待5秒 
    Sleep(5000); 
 
    printf("离开Thread1......\n"); 
 
    // 参数1:信号灯句柄 
    // 参数2:本次操作增加的计数 
    // 参数3:记录以前的计数 
    // 将信号灯计数器加1,是之处于激发状态 
    ReleaseSemaphore(*phSemaphore, 1, NULL); 
    return 0; 

 
int main() 

    /*
     * 信号灯计数为0时,信号灯为nonsingled状态。
     * 也就是说这时用WaitForSingleObject时会等待直到当前数大于0(或超时),
     * 如果不为0时,用WaitForSingleObject就马上返回并把当前数减一;
     */ 
    // 参数1:LPSECURITY_ATTRIBUTES pEventAttributes 安区参数 一般用户不用考虑它,传入NULL。 
    // 参数2:初始化计数个数。 
    // 参数3:计数器最大个数。 
    // 参数4:指定事件的对象的名称,是一个以0结束的字符串指针。名称的字符格式限定在MAX_PATH之内。名字是对大小写敏感的。 
    // 创建同步事件 
    HANDLE hSemaphore = CreateSemaphore(NULL, 2, 2, NULL);  // 将传入Thread1的参数 
 
    // 此时的信号灯计数为2,处于触发状态 
    WaitForSingleObject(hSemaphore, INFINITE); 
    // 此时的信号灯计数为1,处于触发状态 
    WaitForSingleObject(hSemaphore, INFINITE); 
    // 此时的信号灯计数为0,处于未触发状态 
 
 
    // 第1个参数:安全属性,NULL为默认安全属性 
    // 第2个参数:指定线程堆栈的大小。如果为0,则线程堆栈大小和创建它的线程的相同。一般用0 
    // 第3个参数:指定线程函数的地址,也就是线程调用执行的函数地址(用函数名称即可,函数名称就表示地址) 
    // 第4个参数:传递给线程的参数的指针,可以通过传入对象的指针,在线程函数中再转化为对应类的指针 
    // 第5个参数:线程初始状态,0:立即运行;CREATE_SUSPEND:suspended(悬挂) 
    // 第6个参数:用于记录线程ID的地址 
    // 开启新线程,并将同步事件句柄指针传递给新线程 
    HANDLE hThread = (HANDLE)_beginthreadex(NULL, 0, Thread1, &hSemaphore, 0, NULL); 
    // 等待该事件激发 
    WaitForSingleObject(hSemaphore, INFINITE); 
    CloseHandle(hThread);   // 关闭内核对象 
    system("PAUSE"); 
    return 0; 
}

No comments:

Post a Comment