Windows C ++等待线程同步示例

开发者社区2019-07-10204页面浏览量

简介: 本文是一个Windows C ++等待彼此同步线程的示例.

Windows C ++等待线程同步示例

在开发过程中遇到的线程同步问题可以抽象为以下模型:

1. 要继续执行主线程，先决条件是子线程的变量已初始化.

2. 主线程完成执行后windows 线程同步，子线程将继续执行后续的初始化操作.

重复1,2，然后执行...，直到通信结束.

如下所示:

源代码（由VS2010编译和运行）

#include "stdafx.h"
#include <iostream>
using namespace std;
#include <windows.h>
const char* g_pszEventName = "GLOBAL/MY_EVENT";  //事件对象的名称
HANDLE g_hSetTaskIdEvent = NULL;                 //全局Event事件
const int g_iMaxRunCnt = 50;                     //最大的运行次数.
/*
**@brief:模拟线程函数。
**@param:LPVOID pParam 线程参数，未使用（可传递结构体指针等）
**@return 0，ok； 其他代表异常退出。
*/
UINT RecvDataThreadProc(LPVOID pParam)
{
 cout << "The RecvDataThreadProc() is Running!" << endl;
 int nThreadCnt = 0;
 while(nThreadCnt < g_iMaxRunCnt)
 {
  printf("[Thread] The TaskId already Setted! RunCnt = %d\n", nThreadCnt++);
  SetEvent(g_hSetTaskIdEvent); //触发,主线程可以运行.
  WaitForSingleObject(g_hSetTaskIdEvent, INFINITE);
 }
 return 0;
}
/*
**@brief:主线程和副线程交替运行。
**
**
*/
int _tmain(int argc, _TCHAR* argv[])
{
 // 启动一个处理线程
 DWORD dwThreadId = 0;
 HANDLE hRecvThread = CreateThread(NULL, //Choose default security
           0,                             //Default stack size
             (LPTHREAD_START_ROUTINE)&RecvDataThreadProc,//Routine to execute
             (LPVOID) NULL,                              //Thread parameter
              0,                                         //Immediately run the thread
             &dwThreadId                                //Thread Id
             );
 if (NULL == hRecvThread)
 {
  printf("CreateThread Failed! ErrCode: %d\n", GetLastError());
  return(1);
 }
 else
 {
  printf("CreateThread OK!\n");
 }
 CloseHandle(hRecvThread);
 //1.创建命名的事件对象,自动且初始化为无信号状态
 g_hSetTaskIdEvent= CreateEvent(NULL, FALSE, FALSE, (LPCWSTR)(g_pszEventName)); 
 int iErrorCode = GetLastError();
 if (ERROR_ALREADY_EXISTS == iErrorCode)
 {
  printf("[Process]CreateEvent() the object is already exist!\n");
 }
 else if (NULL == g_hSetTaskIdEvent)
 {
  printf("[Process] CreateEvent() Error, Errorcode: %d\n", iErrorCode);
 }
 else
 {
  printf("[Process] CreateEvent() Success!\n");
 }
 unsigned int nRunCnt = 0;
 while(nRunCnt < g_iMaxRunCnt)
 {
  bool bRunNext = false;   //初始置为false,不可以执行下面的操作。
  //等待信号触发
  DWORD dwRst = WaitForSingleObject(g_hSetTaskIdEvent, INFINITE);
  switch(dwRst)
  {
  case WAIT_OBJECT_0:
   // The process terminated.
   printf("[Process]The state of the specified object is signaled.\n");
   bRunNext = true;
   break;
  case WAIT_TIMEOUT:
   // The process did not terminate within the given milliseconds.
   printf("[Process]The time-out interval elapsed, and the object's state is nonsignaled.\n");
   break;
  case WAIT_FAILED:
   // Bad call to function (invalid handle?)
   printf("[Process]WAIT_FAILED, ErrCode: %d\n", GetLastError());
   break;
  }//end switch
  //主线程运行后才可以执行下面的操作.
  if (bRunNext)
  {
   printf("[Process] The Process() Next can running!, running cnt = %d\n", nRunCnt++);
  }
  SetEvent(g_hSetTaskIdEvent);
 }
 CloseHandle(g_hSetTaskIdEvent);
 return 0;
}

基本抽象是: 事件同步机制. 火车票的模型与sunxin教程基本相同.

1. 当遇到复杂的逻辑，例如: 复杂的通信和凌乱的通话时，您必须首先理清思路；

2. 如果无法在全球范围内测试复杂的程序windows 线程同步，则可以将抽象模型视为一个小型演示，然后通过小型演示来测试通用框架逻辑的准确性.

作者: 明义世界

本文来自电脑杂谈，转载请注明本文网址：
http://www.pc-fly.com/a/jisuanjixue/article-146868-1.html