windows多线程编程实现简单（1）

小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序

内容：实现win32下的最基本多线程编程

使用函数：

#CreateThread#
创建线程
HANDLE WINAPI CreateThread(
LPSECURITY_ATTRIBUTES lpThreadAttributes,
SIZE_T dwStackSize,
LPTHREAD_START_ROUTINE lpStartAddress,
LPVOID lpParameter,
DWORD dwCreationFlags,
LPDWORD lpThreadID
);
函数说明：param1 线程内核对象安全属性，一般传入NULL表示使用默认设置
param2 表示线程栈空间大小。传入0，表示默认使用大小1MB
param3 新线程的线程函数地址，多个线程可以使用同一个函数地址
param4 传给线程函数的参数
param5 指定额外的标志来控制线程的创建，为0表示线程创建之后立即可以进行调度，如果为CREATE_SUSPENDED则表示线程创建以后暂停运行，这样无法调度，直到调用ResumeThread（）
param6 返回线程的ID号，传入NULL表示不需要返回该线程ID号
注意：尽量使用 _beginthreadex()代替使用CreateThread().标准C运行库与多线程矛盾。

#WaitForMultipleObjects#
同时等待多个对象的触发，也可以用来事件的分别触发，定时触发。
DWORD WaitForMutilpleObjects(
DWORD nCount,
CONST HANDLE *lpHandles,
BOOL fWaitALL,
DWORD dwMilliseconds,
);
参数 nCount 句柄的最大数最大值为MAXIMUM_WAIT_OBJECTS
HANDLE 句柄数组指针，类型可以为EVENT，Mutex，Process，Thread，Semaphore数组
bWaitAll 等待类型，如果为TRUE，则等待所有信号量再往下执行，FALSE当其中一个信号量有效时就向下执行
dwMilliseconds 超时事件超时后就执行，如果为WSA_INFINTE永不超时，如果没有信号量就会死在这里。

实现代码：线程IMM_PCentry和Def_DeferredTaskEntry交替运行。本程序并未实现同步，只是简单的多线程操作。

#include <windows.h>
#include <stdlib.h>
#include <stdio.h>
#include <process.h> #define SYN int index = ;
HANDLE hMainThread;
HANDLE hIMMthread;
HANDLE hMainThread_ID = ;
HANDLE hIMMthread_ID = ;
#ifdef SYN
HANDLE Mutex_Main;
HANDLE Mutex_Imm;
#endif void WINAPI IMM_PCentry(LPVOID lpParameter)
{
//WaitForSingleObject(hMutex, INFINITE); //第二个参数为INFINITE表示一直等待，直到拥有互斥对象
while (index < )
{
#ifdef SYN
WaitForSingleObject(Mutex_Main, INFINITE);
#endif
index = index + ;
printf("IMM_PCentry hello %d id%d\n", index, hIMMthread_ID);
#ifdef SYN
SetEvent(Mutex_Imm);
#endif
} } void WINAPI Def_DeferredTaskEntry(LPVOID lpParameter)
{
//WaitForSingleObject(hMutex, INFINITE); //第二个参数为INFINITE表示一直等待，直到拥有互斥对象
while (index < )
{
#ifdef SYN
WaitForSingleObject(Mutex_Imm, INFINITE);
#endif
index = index + ;
printf("Def_DeferredTaskEntry hello sharon6 %d id%d\n", index, hMainThread_ID);
#ifdef SYN
SetEvent(Mutex_Main);
#endif
} } int main(void)
{
#ifdef SYN
Mutex_Main = CreateEvent(NULL, , , NULL);
Mutex_Imm = CreateEvent(NULL, , , NULL);
SetEvent(Mutex_Imm);
#endif hMainThread = CreateThread(NULL, , IMM_PCentry, NULL, , &hMainThread_ID);
hIMMthread = CreateThread(NULL, , Def_DeferredTaskEntry, NULL, , &hIMMthread_ID);
WaitForSingleObject(hMainThread, INFINITE);
WaitForSingleObject(hIMMthread, INFINITE);
Sleep();
CloseHandle(hMainThread);
CloseHandle(hIMMthread);
return ;
}

未定义#define SYN时打印结果如下

index为两个线程的共享内存变量。
Def_DeferredTaskEntry线程第一次结束后Count = Count + 1 = 1;
IMM_Pcentry线程开始, 执行完index = index + 1; 线程被Def_DeferredTaskEntry抢占IMM_Pcentry上下文保存了index = 2的值；
Def_DeferredTaskEntry线程开始执行，执行到打印hello 7后，执行到index = index + 1，Def_DeferredTaskEntry线程又被IMM_Pcentry线程抢占，Def_DeferredTaskEntry线程保存线程上下文，包括index = 8；
继续执行上次线程IMM_Pcentry执行的地方，恢复上下文环境，当时保存的是index = 2的值，此时被打印出来。线程IMM_Pcentry继续正常执行。

可以发现，正是因为线程的不断切换，导致index不是每次都加一变化。

为了达到index正常加1的目的，于是利用信号量来实现线程的控制。增加#define SYN宏定义

#CreateEvent#
HANDLE CreateEvent(
LPSECURITY_ATTRIBUTES lpEventAttributes,//安全属性
BOOL bManualReset,//复位方式
BOOL bInitialState,//初始状态
LPCSTR ipName//对象名称
）;

#SetEvent#
一种Win32系统编程事件API
CEvent::SetEvent
BOOL SetEvent(HANDLE hEvent);
其中hEvent表示句柄，返回值；如果操作成功，则返回非零值，否则为0.