C++多线程项目实战代码详解_c++多线程编程实战项目代码

Chapter-1-code1

#include "stdafx.h"
#include <iostream>

//_tmain 相当于main函数，argc,输入参数个数，argv[],参数列表

void _tmain(int argc, _TCHAR* argv[])
{
	std::cout << "Welcome C++ Multithreading CookBook!\t" << std::endl;
	system("pause");
}
1
2
3
4
5
6
7
8
9
10

// chapter-2-code-1.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include <Windows.h>
#include <iostream>

using namespace std;

int _tmain(int argc,_TCHAR* argv[])
{
	//STARTUPINFO用于指定新进程的主窗口特性的一个结构。
	//dword 32位无符号整数
	STARTUPINFO startupInfo = { 0 };

	//PROCESS_INFORMATION在创建进程时相关的数据结构之一，该结构返回有关新进程及其主线程的信息。
	PROCESS_INFORMATION processInformation = { 0 };

	//创建新的进程，主要是打开notepad.exe程序
	BOOL bSuccess = CreateProcess(TEXT("C:/Windows/notepad.exe"), NULL, NULL, NULL, FALSE, NULL, NULL, NULL, &startupInfo, &processInformation);
	
	if (bSuccess)
	{
		cout << "Process started." << endl
			<< "Process ID:\t"
			<< processInformation.dwProcessId << endl;
	}
	else
	{
		cout << "Cannot start process!" << endl
			<< "Error Code:\t" << GetLastError() << endl;
	}
	return system("pause");
}
// chapter2-code-2.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"

#include <Windows.h>
#include <Winternl.h>
#include <iostream>

using namespace std;

// IN 定义输入
typedef NTSTATUS(NTAPI* QEURYINFORMATIONPROCESS)(
	IN HANDLE ProcessHandle,
	IN PROCESSINFOCLASS ProcessInformationClass,
	OUT PVOID ProcessInformation,
	IN ULONG ProcessInformationLength,
	OUT PULONG ReturnLength OPTIONAL
	);

int _tmain(int argc, _TCHAR* argv[])
{

	//STARTUPINFO用于指定新进程的主窗口特性的一个结构。
	//dword 32位无符号整数
	STARTUPINFO startupInfo = { 0 };

	//PROCESS_INFORMATION在创建进程时相关的数据结构之一，该结构返回有关新进程及其主线程的信息。
	PROCESS_INFORMATION processInformation = { 0 };

	//创建新的进程，主要是打开notepad.exe程序
	BOOL bSuccess = CreateProcess(TEXT("C:/Windows/notepad.exe"), NULL, NULL, NULL, FALSE, NULL, NULL, NULL, &startupInfo, &processInformation);

	if (bSuccess)
	{
		cout << "Process started." << endl
			<< "Process ID:\t"
			<< processInformation.dwProcessId << endl;

		PROCESS_BASIC_INFORMATION pbi;
		ULONG uLength = 0;
		HMODULE hDll = LoadLibrary(TEXT("C:/Windows/System32/ntdll.dll"));

		if (hDll)
		{
			QEURYINFORMATIONPROCESS QueryInformationProcess = (QEURYINFORMATIONPROCESS)GetProcAddress(hDll, "NtQueryInformationProcess");
			if (QueryInformationProcess)
			{
				NTSTATUS ntStatus= QueryInformationProcess(
					processInformation.hProcess,
					PROCESSINFOCLASS::ProcessBasicInformation,
					&pbi, sizeof(pbi), &uLength);
				if (NT_SUCCESS(ntStatus))
				{
					cout << "Process ID (from PCB):\t"
						<< pbi.UniqueProcessId << endl;
				}
				else
				{
					cout << "Cannot open PCB@" << endl
						<< "Error Code" << GetLastError() << endl;
				}
			}
		}
		else
		{
			cout << "Cannot load ntdll.dll" << endl
				<< "Error Code" << GetLastError() << endl;
		}

	}
	else
	{
		cout << "Cannot start process!" << endl
			<< "Error Code:\t" << GetLastError() << endl;
	}
	return system("pause");
}

```cpp
// Chapter2-code-3.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include <Windows.h>

#define COMMUNICATION_OBJECT_NAME TEXT("__FILE_MAPPING__")
#define SYNCHRONIZING_MUTEX_NAME TEXT("__TEXT_MUTEX__")

typedef struct _tagCOMMUNICATIONOBJECT
{
	HWND hWndClient;
	BOOL bExitLoop;
	LONG lSleepTimeout;
}COMMUNICATIONOBJECT,*PCOMMUNICATIONOBJECT;

int _tmain(int argc,_TCHAR* argv[])
{
	HBRUSH hBrush = NULL;

	if (_tcscmp(TEXT("blue"), argv[0]) == 0)
	{
		hBrush = CreateSolidBrush(RGB(0, 0, 255));
	}
	else
	{
		hBrush = CreateSolidBrush(RGB(255, 0, 0));
	}
	HWND hWnd = NULL;
	HDC hDC = NULL;
	RECT rectClient = { 0 };
	LONG lWaitTimeout = 0;
	HANDLE hMapping = NULL;
	PCOMMUNICATIONOBJECT pCommObject = NULL;
	BOOL bContinueLoop = TRUE;

	HANDLE hMutex = OpenMutex(MUTEX_ALL_ACCESS,FALSE,SYNCHRONIZING_MUTEX_NAME);
	hMapping = OpenFileMapping(FILE_MAP_READ,FALSE,COMMUNICATION_OBJECT_NAME);

	if (hMapping)
	{
		while (bContinueLoop)
		{
			WaitForSingleObject(hMutex,INFINITE);
			pCommObject = (PCOMMUNICATIONOBJECT)MapViewOfFile(hMapping, FILE_MAP_READ, 0, 0, sizeof(COMMUNICATIONOBJECT));
			if (pCommObject)
			{
				bContinueLoop = !pCommObject->bExitLoop;
				hWnd = pCommObject->hWndClient;
				lWaitTimeout = pCommObject->lSleepTimeout;
				UnmapViewOfFile(pCommObject);//停止内存映射
				hDC = GetDC(hWnd);//获取屏幕
				if (GetClientRect(hWnd,&rectClient))
				{
					FillRect(hDC, &rectClient, hBrush);
				}
				ReleaseDC(hWnd, hDC);
				Sleep(lWaitTimeout);
			}
			ReleaseMutex(hMutex);
		}
	}
	CloseHandle(hMapping);
	CloseHandle(hMutex);
	DeleteObject(hBrush);
    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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183

// Chapter2-code-4.cpp : 定义控制台应用程序的入口点。
//

#include "stdafx.h"
#include <Windows.h>
#include <iostream>

#define COMMUNICATION_OBJECT_NAME TEXT("__FILE_MAPPING__")
#define SYNCHRONIZING_MUTEX_NAME TEXT("__TEXT_MUTEX__")
#define WINDOW_CLASS_NAME TEXT("__TMPWNDCLASS__")
#define BUTTON_CLOSE 100


typedef struct _tagCOMMUNICATIONOBJECT
{
	HWND hWndClient;
	BOOL bExitLoop;
	LONG lSleepTimeout;
}COMMUNICATIONOBJECT, *PCOMMUNICATIONOBJECT;

LRESULT CALLBACK WndProc(HWND hDlg, UINT uMsg, WPARAM wParam, LPARAM lParam);
HWND InitializeWnd();
PCOMMUNICATIONOBJECT pCommObject = NULL;
HANDLE hMapping = NULL;

int _tmain(int argc, _TCHAR* argv[])
{
	HWND hWnd = InitializeWnd();
	HANDLE hMutex = CreateMutex(NULL,FALSE,SYNCHRONIZING_MUTEX_NAME);
	hMapping = CreateFileMapping((HANDLE)-1, NULL, PAGE_READWRITE, 0, sizeof(COMMUNICATIONOBJECT), COMMUNICATION_OBJECT_NAME);
	pCommObject = (PCOMMUNICATIONOBJECT)MapViewOfFile(hMapping, FILE_MAP_WRITE, 0, 0, 0);
	if (pCommObject)
	{
		pCommObject->bExitLoop = FALSE;
		pCommObject->hWndClient = hWnd;
		pCommObject->lSleepTimeout = 250;
		UnmapViewOfFile(pCommObject);

	}
	STARTUPINFO startupInfoRed = { 0 };

	PROCESS_INFORMATION processInformationRed = { 0 };

	STARTUPINFO startupInfoBlue = { 0 };

	PROCESS_INFORMATION processInformationBlue = { 0 };

	BOOL bSuccess = CreateProcess(TEXT("../Debug/Chapter2-code-3.exe"),TEXT("blue"),NULL,NULL,FALSE,0,NULL,NULL,&startupInfoBlue,&processInformationBlue);

	bSuccess = CreateProcess(TEXT("../Debug/Chapter2-code-3.exe"), TEXT("red"), NULL, NULL, FALSE, 0, NULL, NULL, &startupInfoRed, &processInformationRed);

	MSG msg = { 0 };

	while (GetMessage(&msg,NULL,0,0))
	{
		TranslateMessage(&msg);
		DispatchMessage(&msg);
	}
	UnregisterClass(WINDOW_CLASS_NAME, GetModuleHandle(NULL));
	CloseHandle(hMapping);
	CloseHandle(hMutex);

    return 0;
}
LRESULT CALLBACK WndProc(HWND hDlg, UINT uMsg, WPARAM wParam, LPARAM lParam)
{
	switch (uMsg)
	{
	case WM_COMMAND:
	{
		switch (LOWORD(wParam))
		{
		case BUTTON_CLOSE:
		{
			PostMessage(hDlg,WM_CLOSE,0,0);
			break;
		}
		default:
			break;
		}
	}
	case WM_DESTROY:
	{
		pCommObject = (PCOMMUNICATIONOBJECT)MapViewOfFile(hMapping, FILE_MAP_WRITE, 0, 0, 0);
		if (pCommObject)
		{
			pCommObject->bExitLoop = TRUE;
			UnmapViewOfFile(pCommObject);
		}
		PostQuitMessage(0);
		break;
	}
	default:
		return DefWindowProc(hDlg, uMsg, wParam, lParam);
	}
	return 0;
}
HWND InitializeWnd()
{
	WNDCLASSEX wndEx;

	wndEx.cbSize = sizeof(WNDCLASSEX);
	wndEx.style = CS_HREDRAW | CS_VREDRAW;
	wndEx.lpfnWndProc = WndProc;
	wndEx.cbClsExtra = 0;
	wndEx.cbWndExtra = 0;
	wndEx.hInstance = GetModuleHandle(NULL);
	wndEx.hbrBackground = (HBRUSH)(COLOR_WINDOW + 1);
	wndEx.lpszMenuName = NULL;
	wndEx.lpszClassName = WINDOW_CLASS_NAME;
	wndEx.hCursor = LoadCursor(NULL,IDC_ARROW);
	wndEx.hIcon = LoadIcon(wndEx.hInstance,MAKEINTRESOURCE(IDI_APPLICATION));
	wndEx.hIconSm = LoadIcon(wndEx.hInstance, MAKEINTRESOURCE(IDI_APPLICATION));
	if (!RegisterClassEx(&wndEx))
	{
		return NULL;
	}

	HWND hWnd = CreateWindow(wndEx.lpszClassName,TEXT("Interprocess communication Demo"),WS_OVERLAPPEDWINDOW,200,200,400,300,NULL,NULL,wndEx.hInstance,NULL);
	if (!hWnd)
		return NULL;
	HWND hBUTTON=CreateWindow(TEXT("BUTTON"), TEXT("Close"),WS_CHILD|WS_VISIBLE|BS_PUSHBUTTON|WS_TABSTOP,275,225,100,25,hWnd,(HMENU)BUTTON_CLOSE,wndEx.hInstance,NULL);
	HWND hStatic = CreateWindow(TEXT("STATIC"), TEXT(""), WS_CHILD | WS_VISIBLE, 10, 10, 365, 205, hWnd, NULL, wndEx.hInstance, NULL);
	ShowWindow(hWnd, SW_SHOW);
	UpdateWindow(hWnd);
	return hStatic;
}
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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

``