//ThreadAction.h

#pragma once

#ifndef _THREADACTION_H_

#define _THREADACTION_H_

#include "stdafx.h"

#include <Windows.h>

#include <stdio.h>

#include <process.h>

#define MAXTHREADSIZE 3

#define BUFFER_SIZE 16

#define FOR_TIMES 5  //读写次数

void MultiEvents(void);

VOID WriteToBuffer(VOID);

unsigned __stdcall ThreadFunction(LPVOID lpParam);

#endif

---

//ThreadAction.cpp

#include "StdAfx.h"

#include "ThreadAction.h"

HANDLE hWriteEvent[MAXTHREADSIZE];

HANDLE hReadEvent[MAXTHREADSIZE];

LPTSTR szSharedBuffer = new TCHAR[16];

void MultiEvents(void)

{

//创建线程，读共享内存

//主线程写共享内存

//每个线程都有对应的读写同步事件

HANDLE hThread;

DWORD i = 0;

DWORD dwThreadID;

for(i=0;i<FOR_TIMES;++i)

{

//创建写事件

hWriteEvent[i] = CreateEvent(NULL,FALSE,FALSE,NULL);

if (hWriteEvent[i]==NULL)

{

printf("Failed to Create Write Event %d",i);

return;

}

//创建读事件

hReadEvent[i] = CreateEventA(NULL,FALSE,FALSE,NULL);

if (hReadEvent[i] == NULL)

{

printf("Failed to Create Read Event %d",i);

return;

}

//创建线程

hThread = (HANDLE)_beginthreadex(NULL,0,ThreadFunction,(void*)i,0,(unsigned int*)&dwThreadID);

if (hThread == NULL)

{

printf("Failed to Create Thread:%d\n",GetLastError());

return;

}

}

WriteToBuffer();

}

VOID WriteToBuffer(VOID)

{

DWORD dwWaitResult;

DWORD i = 0,j = 0;

for (i=0;i<FOR_TIMES;++i)

{

Sleep(100);

//写入共享内存

wsprintfA((LPSTR)szSharedBuffer,"shared%d",i);

//将线程对应的写事件置为触发，表示写事件完成，读操作可以进行

for(j=0;j<MAXTHREADSIZE;++j)

{

//printf("Succeess\n");

if (!SetEvent(hWriteEvent[j]))

{

printf("Failed to SetEvent %d\n",GetLastError());//第一次调试的时候要发现第一个之后出现了无效句柄,检查之后发现是因为第一次用了i做ID，结果i被修改了，for出错

return;

}

}

//等待所有的线程读完，开始下一次写入

dwWaitResult = WaitForMultipleObjects(MAXTHREADSIZE,hReadEvent,TRUE,INFINITE);

if(dwWaitResult!=WAIT_OBJECT_0)

{

printf("Wait Error %d\n",GetLastError());

ExitProcess(0);

}

}

}

unsigned __stdcall ThreadFunction(LPVOID lpParam)

{

DWORD dwWaitResult;

BYTE lpRead[16];

DWORD i = 0;

DWORD dwThreadIndex = (DWORD)lpParam;

for(i=0;i<FOR_TIMES;++i)

{

dwWaitResult = WaitForSingleObject(hWriteEvent[dwThreadIndex],INFINITE);

switch(dwWaitResult)

{

case WAIT_OBJECT_0:

Sleep(10); //处理数据

CopyMemory(lpRead,szSharedBuffer,16);

break;

default:

printf("Wait Error %d\n",GetLastError());

_endthreadex(dwThreadIndex);

}

//将读事件置为触发

if (!SetEvent(hReadEvent[dwThreadIndex]))

{

printf("Failed to SetEvent : %d\n",GetLastError());

return 0;

}

printf("线程%u 第%d次被读，内容：%s\n",dwThreadIndex,i+1,(LPSTR)lpRead);

}

return 1;

}

---

//main.cpp

#include "stdafx.h"

#include "ThreadAction.h"

int _tmain(int argc, _TCHAR* argv[])

{

MultiEvents();

return 0;

}