首页 > Windows开发 > 详细

WIN通过消息实现互斥同步CreateEvent和SetEvent

时间:2020-06-16 23:22:08      阅读:144      评论:0      收藏:0      [点我收藏+]
// Event0616.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"
#include <WINDOWS.H>
#include <iostream>
HANDLE hEventSet;
HANDLE hEventClear;
//HANDLE hMutex;
DWORD dwM = 10;
DWORD dSignal = 0;
DWORD WINAPI ThreadPro1(LPVOID lpParameter)
{
    for (int i =0; i < dwM; i++)
    {
        WaitForSingleObject(hEventSet,INFINITE);
        dSignal = 1;
        DWORD CurrentID = GetCurrentThreadId();
        fflush(stdin);
        printf("线程%d--生产了--%d件--产品!\n",CurrentID,dSignal);
        SetEvent(hEventClear);
    }
    return 0;
}

DWORD WINAPI ThreadPro2(LPVOID lpParameter)
{
    for (int j =0; j < dwM; j++)
    {
        WaitForSingleObject(hEventClear,INFINITE);
        dSignal = 0;
        DWORD CurrentID = GetCurrentThreadId();
        fflush(stdin);
        printf("线程%d--消费了--%d件--产品!\n",CurrentID,dSignal);
        SetEvent(hEventSet);
    }
    return 0;
}
int main(int argc, char* argv[])
{
    //1.安全属性 2.FALSE通知/TRUE互斥 3.初始有无信号TRUE有/FALSE没有 4.名字
    //hEvent = CreateEvent(NULL,FALSE,FALSE,NULL);

    hEventSet = CreateEvent(NULL,FALSE,TRUE,NULL);
    hEventClear = CreateEvent(NULL,FALSE,FALSE,NULL);
    
    HANDLE hThead[2];
    hThead[0] = ::CreateThread(NULL,0,ThreadPro1,NULL,0,NULL);
    hThead[1] = ::CreateThread(NULL,0,ThreadPro2,NULL,0,NULL);
    
    //SetEvent(hEvent);
    
    WaitForMultipleObjects(sizeof(hThead),hThead,TRUE,INFINITE);
    
    CloseHandle(hThead[0]);
    CloseHandle(hThead[1]);
    CloseHandle(hEventSet);
    CloseHandle(hEventClear);

    
    //printf("Hello World!\n");
    getchar();
    //system("pause");
    return 0;
}

 

WIN通过消息实现互斥同步CreateEvent和SetEvent

原文:https://www.cnblogs.com/ganxiang/p/13149806.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!