windows C++ 互相等待线程同步示例

windows C++ 互相等待线程同步示例

开发中遇到线程同步问题,可抽象为如下模型:

1、主线程的继续执行的前提是子线程的变量已经初始化完毕。

2、子线程待主线程执行完毕后继续执行后续的初始化操作。

重复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教程的火车票模型基本完全一致。

2014-3-20 pm23:47 思于家中床前

作者:铭毅天下

转载请标明出处,原文地址:http://blog.csdn.net/laoyang360/article/details/45646151

如果感觉本文对您有帮助,请点击‘顶’支持一下,您的支持是我坚持写作最大的动力,谢谢!

时间: 2024-11-05 16:33:57

windows C++ 互相等待线程同步示例的相关文章

Windows 互斥对象在线程同步上的运用

互斥对象在线程同步时的使用 1 多线程在资源共享的时候出现的问题 在程序中如果不同线程对同一个对象进行操作的话就有可能出现因为线程切换而导致的问题.例如下面的程序 #include <stdio.h> #include <WinSock2.h> #include <iostream> using namespace std; #pragma comment(lib,"ws2_32.lib") DWORD WINAPIfun1Proc(LPVOID l

线程同步示例

synchronized 关键字的意思,执行方法的时候,当前对象被锁定 下面的示例要对访问b的所有函数要加synchronized ,否则其他调用者会篡改b的值 public class TT implements Runnable {    int b = 100; public synchronized void m1() throws Exception{        //Thread.sleep(2000);        b = 1000;        Thread.sleep(5

windows 线程同步学习测试-1

环境win7旗舰64位系统,vs2013,AMD fx™4100 Auad-core processor ,8G内存, 看<windows核心编程>线程同步一章,看到有说g_x++会不同步的问题,试着写些代码加深印象.发现+1太快了,看不出效果,于是for循环了1亿次.代码如下: #include "stdafx.h" using std::cout; using std::endl; using std::cin; unsigned __stdcall ThreadFun

Delphi 线程同步技术(转)

上次跟大家分享了线程的标准代码,其实在线程的使用中最重要的是线程的同步问题,如果你在使用线程后,发现你的界面经常被卡死,或者无法显示出来,显示混乱,你的使用的变量值老是不按预想的变化,结果往往出乎意料,那么你很有可能是忽略了线程同步的问题. 当有多个线程的时候,经常需要去同步这些线程以访问同一个数据或资源.例如,假设有一个程序,其中一个线程用于把文件读到内存,而另一个线程用于统计文件中的字符数.当然,在把整个文件调入内存之前,统计它的计数是没有意义的.但是,由于每个操作都有自己的 线程,操作系统

delphi线程同步

本文完全摘自网络,仅供自己查询 上次跟大家分享了线程的标准代码,其实在线程的使用中最重要的是线程的同步问题,如果你在使用线程后,发现你的界面经常被卡死,或者无法显示出来,显示混乱,你的使用的变量值老是不按预想的变化,结果往往出乎意料,那么你很有可能是忽略了线程同步的问题. 当有多个线程的时候,经常需要去同步这些线程以访问同一个数据或资源.例如,假设有一个程序,其中一个线程用于把文件读到内存,而另一个线程用于统计文件中的字符数.当然,在把整个文件调入内存之前,统计它的计数是没有意义的.但是,由于每

Windows线程同步总结

Windows线程同步 Windows的线程同步可以利用互斥对象来实现,也可以使用事件对象,关键代码段来实现. 1 事件对象实现线程同步 <1>Event对象创建函数 事件对象的创建事件对象属于内核对象,它包含以三个成员:使用计数,是否是自动重置还是人工重置的布尔值,通知状态的布尔值. HANDLE CreateEvent( LPSECURITY_ATTRIBUTESlpEventAttributes, BOOLbManualReset, BOOLbInitialState, LPCSTRlp

C++windows内核编程笔记day14 其他线程同步技术

线程同步技术: 原子锁 临界区(段) 互斥 事件 信号量(线程示例时已经使用过) 可等候定时器 使用范围:原子锁<临界区<互斥 效率:    原子锁>临界区(用户态)>互斥(内核态) 一般用临界区. //等候多个信号 DWORD WaitForMultipleObjects( DWORD nCount,             // number of handles in array CONST HANDLE *lpHandles,  // object-handle array

C#多线程:深入了解线程同步lock,Monitor,Mutex,同步事件和等待句柄(中)

本篇继续介绍WaitHandler类及其子类 Mutex,ManualResetEvent,AutoResetEvent的用法..NET中线程同步的方式多的让人看了眼花缭乱,究竟该怎么去理解呢?其实,我们抛开.NET环境看线程同步,无非是执行两种操作:一是互斥/加锁,目的是保证临界区代码操作的"原子性":另一种是信号灯操作,目的是保证多个线程按照一定顺序执行,如生产者线程要先于消费者线程执行..NET中线程同步的类无非是对这两种方式的封装,目的归根结底都可以归结为实现互斥/ 加锁或者是

windows下使用Critical Section和Mutex实现线程同步实例

利用critical section 和 Mutex两种不同的线程同步的方法实现生产者消费者问题.生产者线程要能够对一个计数器进行增的操作,并且将其输出在控制台上,消费者线程能够对这个计数器进行减的操作,并将其输出在控制台上.两种线程都共享一个计数器. 其中增.减计数器的数我设置为1-6随机. 测试两种方法的对比,用网上整理出的一张表如下 1.使用CriticalSection 方法时,有一个临界区cs 在将临界区传递给 InitializeCriticalSection 时(或者更准确地说,是