Windows 平台下的同步机制（3）– 事件(Event)

技术2022-07-04 143

事件对象的特点是它可以应用在重叠I/O（overlapped I/0）上，比如说socket编程中有两种模型，一种是重叠I/0，一种是完成端口都是可以使用事件同步。它也是核心对象，因此可以被waitforsingleobje这些函数等待；事件可以有名字，因此可以被其他进程开启。

Event即事件是一种用于进行线程/进程间同步的对象，事件有置位和复位两种状态，当线程通过waiting functions等待Event对象置位时该线程将进入阻塞状态，当该Event对象被置位或等待超时后，等待的线程将恢复执行。Event可以用在一个线程要等待其它线程时。可以使用CreateEvent创建Event对象 HANDLE WINAPI CreateEvent( LPSECURITY_ATTRIBUTES lpEventAttributes, BOOL bManualReset, BOOL bInitialState, LPCTSTR lpName ); lpEventAttributes用于指定Event对象的安全属性，包括句柄是否可被子进程继承和对象的安全描述符。可设置NULL取默认安全属性。 bManualReset表明Event对象是否需要手动复位。如果该参数为TRUE，则Event对象需要通过ResetEvent函数手动复位。如果该参数为FALSE，则Event被创建为自动复位的Event，任何等待的线程被恢复执行后，该Event将被系统自动复位。打个比方，如果有10个线程在等待一个Event，这时将Event置位，如果这是个手动复位Event，那么这10个线程将被依次唤醒直到通过ResetEvent调用将该Event复位；如果Event为自动复位Event，那么10个线程中的第一个被唤醒后Event被自动复位，其它线程将继续等待。 bInitialState参数表明Event对象被创建后默认是否置位。 lpName参数是Event的名字，可以为空表明将创建匿名Event。 CreateEvent函数在调用成功后返回Event句柄。如果同名Event已经存在，则返回这个已经存在了的Event的句柄，此时调用GetLastError函数将返回 ERROR_ALREADY_EXISTS。还可以通过OpenEvent打开一个已经创建的非匿名Event HANDLE WINAPI OpenEvent( DWORD dwDesiredAccess, BOOL bInheritHandle, LPCTSTR lpName ); 在创建或打开了Event对象之后，可以使用SetEvent和ResetEvent函数来置位或复位一个Event对象。 BOOL WINAPI SetEvent( HANDLE hEvent ); BOOL WINAPI ResetEvent( HANDLE hEvent ); 要等待一个或多个Event对象置位可以使用wait functions。简单示例，一个线程不停读取用户输入并放入message列表，另一个线程模拟将message发送出去，如果没有消息，则发送线程处于阻塞状态等待，一旦有消息录入，输入线程将event置位，发送线程即被激活并逐个发送消息。 #include "stdafx.h" #include #include #include #include #include using namespace std;

#ifdef _UNICODE typedef wstring tstring; #define tcout wcout #define tcin wcin #else typedef string tstring; #define tcout cout #define tcin cin #endif /* _UNICODE */

typedef list StringList;

HANDLE hMutex = NULL; HANDLE hEvent = NULL; HANDLE hSendThread = NULL; StringList messages;

bool isRunning;

DWORD WINAPI SendThreadProc(LPVOID lpThreadParameter) { DWORD dw; while(isRunning) { dw = WaitForSingleObject(hEvent, INFINITE); if(dw != WAIT_OBJECT_0) { tcout << _T("Wait error.") << endl; return -1; } dw = WaitForSingleObject(hMutex, INFINITE); if(WAIT_OBJECT_0 != dw && WAIT_ABANDONED != dw) { tcout << _T("Wait error.") << endl; return -2; }

StringList list(messages); messages.clear();

ReleaseMutex(hMutex);

for(StringList::iterator i = list.begin(); i != list.end(); i++) { Sleep(1000); //休眠1秒模拟发送所耗时间

tcout << _T("/* Send Message:") << *i << _T(" */"); }

}

return 0; }

int _tmain(int argc, _TCHAR* argv[]) { hMutex = CreateMutex(NULL, FALSE, NULL); hEvent = CreateEvent(NULL, FALSE, FALSE, NULL); isRunning = true;

hSendThread = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)SendThreadProc, NULL, 0, NULL);

while(isRunning) { tstring s; tcin >> s; if(s == _T("quit")) { isRunning = true; break; }

DWORD dw = WaitForSingleObject(hMutex, INFINITE); if(WAIT_OBJECT_0 != dw && WAIT_ABANDONED != dw) { tcout << _T("Wait error.") << endl; return -1; } messages.push_back(s); ReleaseMutex(hMutex); SetEvent(hEvent); }

CloseHandle(hMutex); CloseHandle(hEvent); CloseHandle(hSendThread);

return 0;

}

专利

最新回复(0)

Windows 平台下的同步机制 （3）– 事件(Event)

专利

Windows 平台下的同步机制（3）– 事件(Event)