做为一名分布式服务器开发人员，在服务器开发领域、多线程开发和并发编程方面有自己的心得和经验，愿意分享给同仁，今讨论下Windows下线程并发程序开发。
下面用用两个线程实现一个简单的数组排序，演示了线程的基本用法。
原理是：
为了节省执行时间而添加并行，把问题划分为几个小问题，并分配给几个线程（分而治之），把问题划分成若干更小的单元，更容易在实现中创建并行逻辑。同时，在并行中使用系统资源能优化应用程序并提高其运行速度。
|
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
|
#include "stdafx.h"
#include <iostream>
#include <Windows.h>
#include <Winternl.h>
#include <tchar.h>
#include <winbase.h>
using
namespace
std;
#define THREADS_NUMBER 2
#define ELEMENTS_NUMBER 200
#define BLOCK_SIZE ELEMENTS_NUMBER / THREADS_NUMBER
#define MAX_VALUE 1000
typedef
struct
_tagARRAYOBJECT
{
int
* iArray;
int
iSize;
int
iThreadID;
} ARRAYOBJECT, *PARRAYOBJECT;
DWORD
WINAPI ThreadStart(
LPVOID
lpParameter);
void
PrintArray(
int
* iArray,
int
iSize);
void
MergeArrays(
int
* leftArray,
int
leftArrayLenght,
int
* rightArray,
int
rightArrayLenght,
int
* mergedArray);
int
_tmain(
int
argc, _TCHAR* argv[])
{
int
iArray1[BLOCK_SIZE];
int
iArray2[BLOCK_SIZE];
int
iArray[ELEMENTS_NUMBER];
for
(
int
iIndex = 0; iIndex < BLOCK_SIZE; iIndex++)
{
iArray1[iIndex] =
rand
() % MAX_VALUE;
iArray2[iIndex] =
rand
() % MAX_VALUE;
}
HANDLE
hThreads[THREADS_NUMBER];
ARRAYOBJECT pObject1 = { &(iArray1[0]), BLOCK_SIZE, 0 };
hThreads[0] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadStart,(
LPVOID
)& pObject1, 0, NULL);
ARRAYOBJECT pObject2 = { &(iArray2[0]), BLOCK_SIZE, 1 };
hThreads[1] = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)ThreadStart, (
LPVOID
)& pObject2, 0, NULL);cout<<
"Waiting execution..."
<< endl;
WaitForMultipleObjects(THREADS_NUMBER, hThreads, TRUE, INFINITE);
MergeArrays(&iArray1[0], BLOCK_SIZE, &iArray2[0], BLOCK_SIZE, &iArray[0]);
PrintArray(iArray, ELEMENTS_NUMBER);
CloseHandle(hThreads[0]);
CloseHandle(hThreads[1]);
cout<<
"Array sorted..."
<< endl;
getchar
();
return
0;
}
DWORD
WINAPI ThreadStart(
LPVOID
lpParameter)
{
PARRAYOBJECT pObject = (PARRAYOBJECT)lpParameter;
int
iTmp = 0;
for
(
int
iIndex = 0; iIndex < pObject->iSize; iIndex++)
{
for
(
int
iEndIndex = pObject->iSize - 1; iEndIndex > iIndex; iEndIndex--)
{
if
(pObject->iArray[iEndIndex] < pObject->iArray[iIndex])
{
iTmp = pObject->iArray[iEndIndex];
pObject->iArray[iEndIndex] = pObject->iArray[iIndex];
pObject->iArray[iIndex] = iTmp;
}
}
}
return
0;
}
void
PrintArray(
int
* iArray,
int
iSize)
{
for
(
int
iIndex = 0; iIndex < iSize; iIndex++)
{
cout <<
" "
<< iArray[iIndex];
}
cout << endl;
}
void
MergeArrays(
int
* leftArray,
int
leftArrayLenght,
int
* rightArray,
int
rightArrayLenght,
int
* mergedArray)
{
int
i = 0;
int
j = 0;
int
k = 0;
while
(i < leftArrayLenght && j < rightArrayLenght)
{
if
(leftArray[i] < rightArray[j])
{
mergedArray[k] = leftArray[i];
i++;
}
else
{
mergedArray[k] = rightArray[j];
j++;
}
k++;
}
if
(i >= leftArrayLenght)
{
while
(j < rightArrayLenght)
{
mergedArray[k] = rightArray[j];
j++;
k++;
}
}
if
(j >= rightArrayLenght)
{
while
(i < leftArrayLenght)
{
mergedArray[k] = leftArray[i];
i++;
k++;
}
}
}
|
运行结果：
中间在编译运行的时候会遇到一些细节问题，特此说明：
出现错误：
错误 C1189 #error: "No Target Architecture"
设置如下即可：在_X86_
分布式开发，服务器开发，多线程开发，并发程序设计，任重而道远。
本文转自 liam2199 博客，原文链接：http://blog.51cto.com/liam2199/1963538 如需转载请自行联系原作者
