首先声明,这里的工作线程与UI线程是相对的,即没有任何窗口的。如果需要与主线程或其它辅助线程通讯,有几种方法如事件、消息和信号等,也可以是以上几种方法的综合运用。下面就列出以下3种通讯方法的代码框架。
只用消息通讯
1
DWORD ThreadProc(LPVOID lParam)
2![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedBlockStart.gif)
{
3
//创建线程消息队列
4
MSG msg;
5
PeekMessage(&msg, NULL, WM_USER, WM_USER, PM_NOREMOVE);
6
//通知其它线程消息队列已创建好
7
SetEvent(hEvent);
8
9
while(true)
10![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
11
GetMessage(&msg, NULL, 0, 0);
12
switch(msg.message)
13![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
14
case WM_QUIT:
15
return 1;
16![](http://www.cppblog.com/Images/OutliningIndicators/InBlock.gif)
17
//自定义消息1处理
18
case WM_USER + 100:
19
break;
20![](http://www.cppblog.com/Images/OutliningIndicators/InBlock.gif)
21
//自定义消息2处理
22
case WM_USER + 101:
23
break;
24
}
25
}
26
return 0;
27
}
只用事件通讯
1
DWORD ThreadProc(LPVOID lParam)
2![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedBlockStart.gif)
{
3
DWORD dwIndex;
4
while (true)
5![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
6
dwIndex = WaitForMultipleObjects(cObjects, pObjects, FALSE, INFINTE);
7
if (WAIT_OBJECT + 0== dwIndex)
8![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
9
return 1; //假设为退出事件
10
}
11
else if (WAIT_OBJECT + 1 == dwIndex)
12![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
13
//事件1受信,处理之
14
}
15
16
else if (WAIT_OBJECT + cObjects - 1 == dwIndwx)
17![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
18
//事件cObjects - 1受信, 处理之
19
}
20
}
21
}
用消息和事件通讯
1
DWORD ThreadProc(LPVOID lParam)
2![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedBlockStart.gif)
{
3
while (TRUE)
4![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
5
DWORD ret ;
6
MSG msg ;
7
8
while (PeekMessage(&msg, NULL, 0, 0, PM_REMOVE))
9![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
10
switch(msg.message)
11![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
12
//线程退出消息,直接返回
13
case WM_QUIT:
14
return 1;
15![](http://www.cppblog.com/Images/OutliningIndicators/InBlock.gif)
16
//自定义消息1处理
17
case WM_USER + 100:
18
break;
19
//自定义消息2处理
20
case WM_USER + 101:
21
break;
22
}
23
}
24
ret = MsgWaitForMultipleObjects(cObjects, lphObjects, FALSE,INFINITE,QS_POSTMESSAGE);
25
if (ret == (WAIT_OBJECT_0 + cObjects))
26![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
27
//有新的消息到来,继续到上步PeekMessage处理
28
continue;
29
}
30
else
31![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
32
//是事件受信了
33
if (ret == WAIT_OBJECT_O)
34![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
35
}
36
else if (ret == WAIT_OBJECT_O + 1)
37![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
38
}
39
else if(ret == WAIT_OBJECT_O + cObjects - 1)
40![](http://www.cppblog.com/Images/OutliningIndicators/ExpandedSubBlockStart.gif)
{
41
}
42
}
43
return 0;
44
} 上面用到了GetMessage和PeekMessage 函数,这两者都是从消息队列取出消息,不同的是GetMessage从消息队列删除消息,并且阻塞调用线程。PeekMessage则是查询消息队列,如果有消息就取出,没有消息也立即返回,是否从消息队列删除消息由最后一个参数决定:PM_REMOVE表示删除,PM_NOREMOVE表示不删除。可以简单地认为,GetMessage是同步的,PeekMessage是异步的。
posted @
2009-04-15 18:11 春秋十二月 阅读(6225) |
评论 (5) |
编辑 收藏
ACE中的同步机制是轻量级高效的,它不同于MFC中的同步类,MFC中的同步类采用了类继承的方式,而ACE并没有用继承方式,各个不同的锁类是平行的关系,这些类支持相同的接口,即它们的所有公共方法是相同的,因此可被适配用于动态绑定和替换,这种动态绑定是没有虚函数调用开销的,且这些方法代码短小使用了内联实现。应用程序开发者可以通过指定模板实参来使用不同的锁,并可在运行时动态替换。
ACE中的锁是易于使用的,既有互斥锁(ACE_Mutex)又有读写锁(ACE_RW_Mutex),这些锁又细分为专门用于线程同步(ACE_Thread_Mutex,ACE_RW_Thread_Mutex)和进程(ACE_Process_Mutex,ACE_RW_Process_Mutex)同步的特定锁。相比MFC高级的是ACE中还提供了递归互斥体(ACE_Token),可有效地用于某些递归例程。
ACE中提供了ACE_Lock锁抽象基类和ACE_Adapter_Lock锁适配器模板类,ACE_Adapter_Lock从ACE_Lock继承,实现了动态绑定和替换。另外,ACE还提供了ACE_Atomic_Op模板类,重载了基本的算术运算符,实现了原子化算术运算。
posted @
2009-04-02 16:33 春秋十二月 阅读(2008) |
评论 (1) |
编辑 收藏