现在的位置: 首页 > 自动控制 > 工业·编程 > 正文

线程同步—-WaitForSingleObject与WaitForMultipleObject

2013-01-21 06:41 工业·编程 ⁄ 共 1761字 ⁄ 字号 暂无评论

WaitForSingleObject函数在线程同步中最为常见,以至于没有太多的话题还需要展开,

那就写一下容易被忽略的细节,引用书中一个例子

[cpp] view plaincopy

  1. DWORD dw = WaitForSingleObject(hProcess, 5000) 
  2. switch(dw) 
  3. case WAIT_OBJECT_0: 
  4. break; 
  5. case WAIT_TIMEOUT: 
  6. break; 
  7. case WAIT_FAILED: 
  8. break; 

hProcess是进程句柄,进城同属内核对象,在创建进程后进程就被标识为无信号,

直到进程寿终正寝。上面的选择语句给了时间限制,5秒钟,如果在五秒钟的等待过去

后进程仍然苟延残喘,那么就会有返回值WAIT_TIMEOUT,如果在五秒钟内进程就

挂掉了,随之内核对象变成有信号,选择语句就会返回WAIT_OBJECT_0。

并不是每个等待都如此简单,有时候等到的是自己创建的时间内核对象,而事件又分为自动重

置和手动重置,各有利弊,但在WaitForSingleObject中表现的还不够淋漓尽致,

下面用WaitForMultipleObject举例说明,说明时主要针对一些一点和重点展开;

1.

[cpp] view plaincopy

  1. HANDLE h[3]; 
  2. h[0] = hProcess1; 
  3. h[1] = hProcess2; 
  4. h[2] = hProcess3; 
  5. DWORD dw = WaitForMultipleObjects(3, h, FALSE, 5000); 
  6. switch(dw) 
  7. case WAIT_FAILED: 
  8. break; 
  9. case WAIT_TIMEOUT: 
  10. break; 
  11. case WAIT_OBJECT_0 + 0; 
  12. break; 
  13. case WAIT_OBJECT_0 + 1; 
  14. break; 
  15. case WAIT_OBJECT_0 + 2; 
  16. break; 

在以上代码中假如创建了三个进程,其中一个进程驾鹤西去,信号从无到有,上面的

等待将被打破,再假如hProces1去了,则switch必定返回WAIT_OBJECT_0+1,

这是正确的,但是,一般我们的程序不是到此处就停止,毕竟三个进程内核对象呢,

不可能死了一个我们的这段代码就没意义了,要是那样的话也根本没必要圈进去三个内核对

象。恩,程序继续执行,再次运行到等待函数时发现那个死了的进程留下的句柄还是有信号

的,于是这时候即使进程3也死了也不会返回最后一个case,而是提前反回了case 2。

结论:要在每个case返回处进行得当处理,以保证再次返回时不受影响。

2.

[cpp] view plaincopy

  1. HANDLE g_hEvent; 
  2. int WINAPI _tWinMain(...) 
  3.    g_hEvent = CreateEvent(NULL, FALSE, FALSE, NULL); 
  4. HANDLE hThread1 =   _beginthreadex(); 
  5. HANDLE hThread2 =   _beginthreadex(); 
  6.    SetEvent(g_hEvent); 
  7. DWORD WINAPI ThreadProc1() 
  8.    WaitForSingleObject(g_hEvent, INFINITE); 
  9. // ...
  10.    SetEvent(g_hEvent); 
  11. DWORD WINAPI ThreadProc2() 
  12.    WaitForSingleObject(g_hEvent, INFINITE); 
  13. // ...
  14.    SetEvent(g_hEvent); 

如上,创建的事件为自动方式,在WaitForSingleObject后会将信号变为无效,必须在访问

省略号中间部分之后重新置为有信号,重置信号后可以继续进行两个线程的代码执行,

这里唯一需要知道是程序没办法给两个线程公平的分配出机会来在有信号的瞬间获得代码处理

机会,很有可能一个线程刚刚处理完一段代码然后将事件从无信号变为有信号,接着就有

等待到了执行代码的机会(WaitForSingleObject成功)。

此外,还应注意,如果我们的程序在使用手动重置事件时,如果允许两个线程同时运行,如一

个来做事件a一个来做事件b,那就一定要保证这两个线程不发生数据访问的冲突,至少不可

以同时写一段内存,一个数据。

给我留言

留言无头像?