随笔-103  评论-224  文章-30  trackbacks-0
 
   在WINDOWS NT4.0 以上操作系统中,串口通讯有2种模式:同步方式和异步方式。由CreateFile中的dwFlagsAndAttributes参数决定,若指定FILE_FLAG_OVERLAPPED标志则为异步方式,否则为同步方式。当为同步模式时,调用ReadFileWriteFile会阻塞调用线程直到读完或写完指定量的数据才返回,这样就有可能出现无法退出程序的现象,解决方法是为读写操作设置超时,注意这种超时指的是ReadFileWriteFile函数的返回时间,仅对同步模式有效。代码如下
 1   //以下m_pComPort为本人自己封装的C++串口类CComPort的指针
 2    
 3            // FALSE表示以同步方式打开
 4           m_pComPort->Open(2, FALSE, 38400);
 5     
 6          //设置读写超时为5秒
 7               COMMTIMEOUTS  timeout = 0 };
 8           timeout.ReadTotalTimeoutConstant = 5000;
 9           timeout.WriteTotalTimeoutConstant = 5000;
10          m_pCommPort->SetTimeouts(timeout);
11
12            char  szData[1024= 0 };
13         //读数据
14         DWORD dwRet = m_pCommPort->ReadComm(szData, 1024);
15         //写数据
16         dwRet = m_pCommPort->WriteComm(szData, 1024);
17         //关闭串口
18         m_pCommPort->Close();
   当为异步模式时,由于读写操作会立即返回,因此设置超时指的是设置等待操作完成的时间,而不是ReadFileWriteFile函数返回的时间,代码如下
 1    //以下m_pComPort为本人自己封装的C++串口类CComPort的指针
 2     
 3           // TRUE表示以异步方式打开
 4            m_pComPort->Open(2, TRUE, 38400);
 5      
 6          //设置读写等待超时为5秒
 7                char  szData[1024= 0 };
 8  
 9         //当第3个参数为0时,读写操作会立即返回
10           //读数据
11           DWORD dwRet = m_pCommPort->ReadComm(szData, 10245000);
12          //写数据
13           dwRet = m_pCommPort->WriteComm(szData, 10245000);
14          //关闭串口
15           m_pCommPort->Close();
   这里的ReadCommWriteComm的实现内部针对不同模式作了不同处理,异步模式时即调用了WaitForSingleObject等待函数来设置超时。同步模式时即调用不带重叠结构的ReadFileWriteFile函数来接收或发送指定量的数据。另外在这介绍下串口虚拟软件vspd,这个软件能模拟在同一台计算机上进行两个串口的通讯,有利于没有实际设备情况下的串口调试。
posted @ 2009-04-17 19:15 春秋十二月 阅读(3741) | 评论 (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 @ 2009-04-15 18:11 春秋十二月 阅读(5986) | 评论 (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 春秋十二月 阅读(1910) | 评论 (1)编辑 收藏
仅列出标题
共11页: First 3 4 5 6 7 8 9 10 11