win32 console 下多线程同步 - VC++/MFC - C++论坛

楼主

已结贴√ 问题点数：10 回复次数：2

win32 console 下多线程同步

程序代码：

#include <windows.h>
#include <iostream.h>

DWORD WINAPI Fun1Proc(
  LPVOID lpParameter   // thread data
);

DWORD WINAPI Fun2Proc(
  LPVOID lpParameter   // thread data
);

int tickets=100;
HANDLE g_hEvent;

void main()
{
    HANDLE hThread1;
    HANDLE hThread2;
    hThread1=CreateThread(NULL,0,Fun1Proc,NULL,0,NULL);
    hThread2=CreateThread(NULL,0,Fun2Proc,NULL,0,NULL);
    CloseHandle(hThread1);
    CloseHandle(hThread2);

        g_hEvent=CreateEvent(NULL,FALSE,FALSE,"tickets");
    if(g_hEvent)
    {
        if(ERROR_ALREADY_EXISTS==GetLastError())
        {
            cout<<"only instance can run!"<<endl;
            return;
        }
    }
    SetEvent(g_hEvent);

    Sleep(4000);
    CloseHandle(g_hEvent);
}

DWORD WINAPI Fun1Proc(
  LPVOID lpParameter   // thread data
)
{
    while(TRUE)
    {
        WaitForSingleObject(g_hEvent,INFINITE);
        if(tickets>0)
        {
            Sleep(1);
            cout<<"thread1 sell ticket : "<<tickets--<<endl;
            SetEvent(g_hEvent);
        }
        else
        {    SetEvent(g_hEvent);
            break;
        }
       
    }
   
    return 0;
}

DWORD WINAPI Fun2Proc(
  LPVOID lpParameter   // thread data
)
{
   
    while(TRUE)
    {
        WaitForSingleObject(g_hEvent,INFINITE);
//        ResetEvent(g_hEvent);
        if(tickets>0)
        {
            Sleep(1);
            cout<<"thread2 sell ticket : "<<tickets--<<endl;
            SetEvent(g_hEvent);
        }
        else
        {
            SetEvent(g_hEvent);
            break;
        }
       
    }
   
    return 0;
}

为什么这样多线程不能同步。还是说只能在win32Application 和MFC下才行。

搜索更多相关主题的帖子: 多线程　

g_hEvent=CreateEvent(NULL,FALSE,FALSE,L"tickets"); if(g_hEvent) { if(ERROR_ALREADY_EXISTS==GetLastError()) { cout<<"only instance can run!"<<endl; return; } } HANDLE hThread1; HANDLE hThread2; hThread1=CreateThread(NULL,0,Fun1Proc,NULL,0,NULL); hThread2=CreateThread(NULL,0,Fun2Proc,NULL,0,NULL); CloseHandle(hThread1); CloseHandle(hThread2); SetEvent(g_hEvent); Sleep(4000); CloseHandle(g_hEvent);