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

简介: windows C++ 互相等待线程同步示例开发中遇到线程同步问题,可抽象为如下模型:1、主线程的继续执行的前提是子线程的变量已经初始化完毕。2、子线程待主线程执行完毕后继续执行后续的初始化操作。重复1,2执行……直到通信结束。

如下图所示:image.png

源码(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;

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

本质抽象为:事件同步机制。和sunxin教程的火车票模型基本完全一致。

【反思】

1.当遇到复杂的逻辑,如:通信复杂、调用混乱,一定要先把思路梳理清楚;

2.当复杂的程序无法进行全局测试的时候,可以考虑抽象模型为小Demo,通过小Demo测试大致框架逻辑的准确性。


相关文章
|
3月前
|
缓存 安全 C++
C++无锁队列:解锁多线程编程新境界
【10月更文挑战第27天】
190 7
|
3月前
|
消息中间件 存储 安全
|
4月前
|
存储 消息中间件 资源调度
C++ 多线程之初识多线程
这篇文章介绍了C++多线程的基本概念,包括进程和线程的定义、并发的实现方式,以及如何在C++中创建和管理线程,包括使用`std::thread`库、线程的join和detach方法,并通过示例代码展示了如何创建和使用多线程。
83 1
|
4月前
|
存储 并行计算 安全
C++多线程应用
【10月更文挑战第29天】C++ 中的多线程应用广泛,常见场景包括并行计算、网络编程中的并发服务器和图形用户界面(GUI)应用。通过多线程可以显著提升计算速度和响应能力。示例代码展示了如何使用 `pthread` 库创建和管理线程。注意事项包括数据同步与互斥、线程间通信和线程安全的类设计,以确保程序的正确性和稳定性。
|
4月前
|
存储 前端开发 C++
C++ 多线程之带返回值的线程处理函数
这篇文章介绍了在C++中使用`async`函数、`packaged_task`和`promise`三种方法来创建带返回值的线程处理函数。
173 6
|
4月前
|
缓存 负载均衡 Java
c++写高性能的任务流线程池(万字详解!)
本文介绍了一种高性能的任务流线程池设计,涵盖多种优化机制。首先介绍了Work Steal机制,通过任务偷窃提高资源利用率。接着讨论了优先级任务,使不同优先级的任务得到合理调度。然后提出了缓存机制,通过环形缓存队列提升程序负载能力。Local Thread机制则通过预先创建线程减少创建和销毁线程的开销。Lock Free机制进一步减少了锁的竞争。容量动态调整机制根据任务负载动态调整线程数量。批量处理机制提高了任务处理效率。此外,还介绍了负载均衡、避免等待、预测优化、减少复制等策略。最后,任务组的设计便于管理和复用多任务。整体设计旨在提升线程池的性能和稳定性。
129 5
|
4月前
|
C++
C++ 多线程之线程管理函数
这篇文章介绍了C++中多线程编程的几个关键函数,包括获取线程ID的`get_id()`,延时函数`sleep_for()`,线程让步函数`yield()`,以及阻塞线程直到指定时间的`sleep_until()`。
66 0
|
4月前
|
资源调度 Linux 调度
Linux C/C++之线程基础
这篇文章详细介绍了Linux下C/C++线程的基本概念、创建和管理线程的方法,以及线程同步的各种机制,并通过实例代码展示了线程同步技术的应用。
68 0
Linux C/C++之线程基础
|
6月前
|
Java Windows
【Azure Developer】Windows中通过pslist命令查看到Java进程和线程信息,但为什么和代码中打印出来的进程号不一致呢?
【Azure Developer】Windows中通过pslist命令查看到Java进程和线程信息,但为什么和代码中打印出来的进程号不一致呢?
|
6月前
|
Dart 编译器 API
Dart ffi 使用问题之在C++线程中无法直接调用Dart函数的问题如何解决
Dart ffi 使用问题之在C++线程中无法直接调用Dart函数的问题如何解决