开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > 多显示器编程 > 查看源码
ThreadComm.cpp
资源名称：第6章 多线程编程.rar　[点击查看]
上传用户：gyjjlc
上传日期：2013-03-29
资源大小：2124k
文件大小：3k
源码类别：

多显示器编程

开发平台：

C++ Builder

ThreadComm.cpp：源码内容
  1. //---------------------------------------------------------------------------
  2. #include <vcl.h>
  3. #pragma hdrstop
  4. #include "ThreadComm.h"
  5. #include "UnitMain.h"
  7. #pragma package(smart_init)
  8. __fastcall ThreadComm::ThreadComm(bool CreateSuspended)
  9.     : TThread(true)
  10. {
  11.     //线程终止时自动释放内存
  12.     FreeOnTerminate=true;
  13.     //发送缓冲区的计数器清0
  14.     sendCount=0;
  15.     if(CreateSuspended==false)
  16.         Resume();//启动线程
  17. }
  18. //---------------------------------------------------------------------------
  19. void __fastcall ThreadComm::Execute()
  20. {
  21.     DWORD dwEvtMask,dwTransfer;
  22.     //等待通信事件函数重叠操作所要求的重叠数据结构
  23.     OVERLAPPED  os;
  24.     memset(&os,0,sizeof(OVERLAPPED));
  25.     // 为等待通信事件建立信号事件，手工复位方式，初始状态FALSE
  26.     os.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
  27.     //设置所要等待的通信事件，收到有效字符或发送缓冲区为空
  28.     if(!SetCommMask(FormMain->COMX->hCom,EV_RXCHAR|EV_TXEMPTY))
  29.     {
  30.         MessageBox(NULL,"设置通信设备控制块数据结构操作异常！","错误",MB_OK);
  31.         return;
  32.     }
  33.     //线程终止标志无效，一直循环
  34.     while(!Terminated)
  35.     {
  36.         dwEvtMask=0;
  37.         //等待设定的通信事件发生
  38.         if (!WaitCommEvent(FormMain->COMX->hCom, &dwEvtMask, &os))
  39.         {
  40.             //重叠操作处于后台执行的情况
  41.             if(GetLastError()==ERROR_IO_PENDING)
  42.             {
  43.                 if(GetOverlappedResult(FormMain->COMX->hCom,&os,&dwTransfer,TRUE))//;
  44.                     os.Offset+=dwTransfer;
  45.             }
  46.         }
  47.         //收到有效字符事件发生
  48.         if ((dwEvtMask & EV_RXCHAR)==EV_RXCHAR)
  49.         {
  50.             recvBuffer=FormMain->COMX->ReceiveProcess();
  51.             if(!recvBuffer.IsEmpty())
  52.             {
  53.                 //收到字符送主窗体
  54.                 Synchronize(AddToMemo);
  55.             }
  56.         }
  57.         //发送缓冲区空，即可以发送的情况
  58.         if((sendCount>0)&&((dwEvtMask & EV_TXEMPTY)==EV_TXEMPTY))
  59.         {
  60.             //将发送缓冲区中当前位置的字符发送出去
  61.             SendOneByte();
  62.         }
  63.     }
  64.     MessageBox(NULL,"线程终止！","信息",MB_OK);
  65. }
  66. //---------------------------------------------------------------------------
  67. //为线程同步函数所调用
  68. void __fastcall ThreadComm::AddToMemo(void)
  69. {
  70.     //调主窗体成员函数，将收到字符串送主窗体的有关的VCL控件
  71.     FormMain->CommInputProc(recvBuffer);
  72. }
  73. //---------------------------------------------------------------------------
  74. //将发送缓冲区中当前位置的字符发送出去，发送缓冲区计数器减1
  75. bool __fastcall ThreadComm::SendOneByte(void)
  76. {
  77.     bool bCode;
  78.     //调用块发送函数将发送缓冲区中当前位置的字符发送出去
  79.     bCode=FormMain->COMX->WriteCommBlock(sendBuffer.SubString
  80.         (sendBuffer.Length()-sendCount+1,1).c_str(),1);
  81.     if(bCode)sendCount--;
  82.     return bCode;
  83. }