随笔-88  评论-224  文章-23  trackbacks-0
   首先声明,这里的工作线程与UI线程是相对的,即没有任何窗口的。如果需要与主线程或其它辅助线程通讯,有几种方法如事件、消息和信号等,也可以是以上几种方法的综合运用。下面就列出以下3种通讯方法的代码框架。

   只用消息通讯
 1  DWORD ThreadProc(LPVOID lParam)
 2  {
 3      //创建线程消息队列
 4      MSG msg;
 5      PeekMessage(&msg, NULL, WM_USER, WM_USER, PM_NOREMOVE);
 6      //通知其它线程消息队列已创建好
 7      SetEvent(hEvent); 
 8  
 9      while(true)
10    {
11        GetMessage(&msg, NULL, 00);
12        switch(msg.message)
13         {
14            case WM_QUIT:
15                  return 1;
16
17            //自定义消息1处理
18            case WM_USER + 100:
19                  break;
20
21            //自定义消息2处理
22            case WM_USER + 101:
23                  break;
24         }

25    }

26    return 0;
27 }
 
   只用事件通讯 
 1  DWORD ThreadProc(LPVOID lParam)
 2  {
 3       DWORD dwIndex;
 4       while (true)
 5       {
 6           dwIndex = WaitForMultipleObjects(cObjects, pObjects, FALSE, INFINTE);
 7           if (WAIT_OBJECT + 0== dwIndex)
 8            {
 9               return 1;     //假设为退出事件
10         }

11         else if (WAIT_OBJECT + 1 == dwIndex)
12         {
13             //事件1受信,处理之
14         }

15         
16         else if (WAIT_OBJECT + cObjects - 1 == dwIndwx)
17         {
18             //事件cObjects - 1受信, 处理之
19         }

20     }

21 }

   用消息和事件通讯
 1 DWORD ThreadProc(LPVOID lParam)
 2 {
 3    while (TRUE)
 4   {
 5         DWORD ret ; 
 6         MSG msg ; 
 7   
 8         while (PeekMessage(&msg, NULL, 00, PM_REMOVE)) 
 9         
10         switch(msg.message)
11          {
12            //线程退出消息,直接返回
13             case WM_QUIT:
14                 return 1;
15
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        {
27           //有新的消息到来,继续到上步PeekMessage处理
28           continue;
29        }
 
30        else 
31        
32           //是事件受信了
33          if (ret == WAIT_OBJECT_O)
34          {               
35          }

36          else if (ret == WAIT_OBJECT_O + 1)
37          {
38          }

39          else if(ret == WAIT_OBJECT_O + cObjects - 1)
40          {
41          }

42       }
    
43     return 0;
44 }
   上面用到了GetMessage和PeekMessage 函数,这两者都是从消息队列取出消息,不同的是GetMessage从消息队列删除消息,并且阻塞调用线程。PeekMessage则是查询消息队列,如果有消息就取出,没有消息也立即返回,是否从消息队列删除消息由最后一个参数决定:PM_REMOVE表示删除,PM_NOREMOVE表示不删除。可以简单地认为,GetMessage是同步的,PeekMessage是异步的。
posted on 2009-04-15 18:11 春秋十二月 阅读(4942) 评论(5)  编辑 收藏 引用 所属分类: C/C++

评论:
# re: 工作线程的相关消息循环 2009-04-16 09:59 | Sandy
不错,受益了.  回复  更多评论
  
# re: 工作线程与消息循环 2014-01-17 14:21 | 王继
ret = MsgWaitForMultipleObjects(cObjects, lphObjects, FALSE,INFINITE,QS_POSTMESSAGE);
cObjects lphObjects 这俩是啥东西,如何声明,做什么用。  回复  更多评论
  
# re: 工作线程与消息循环 2014-01-17 18:51 | 春秋十二月
@王继
cobjects--可等待内核对象个数,DWORD类型
lphobjects--可等待内核对象数组,const HANDLE*类型  回复  更多评论
  
# re: 工作线程与消息循环 2014-03-04 11:49 | 没完没了
第一个实例中: PeekMessage(&msg, NULL, WM_USER, WM_USER, PM_NOREMOVE);
可以去掉.
其它线程给这个线程发送消息:
PostThreadMessage(这个线程id, 消息id, 0, 0);  回复  更多评论
  
# re: 工作线程与消息循环 2015-12-01 17:17 | mmocake
从消息队列取出消息 mark了  回复  更多评论
  

只有注册用户登录后才能发表评论。
【推荐】超50万行VC++源码: 大型组态工控、电力仿真CAD与GIS源码库
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理