当前位置：网站首页>Window下线程与线程同步总结
Window下线程与线程同步总结
2022-07-05 09:55:00 【陈子青 ：See】
目录
线程创建函数 CreateThread与_beginthreadex
等待函数 WaitForSingleObject 和 WaitForMultipleObjects
一 线程创建与使用
线程创建函数 CreateThread与_beginthreadex
CreateThread是一种微软在Windows API中提供了建立新的线程的函数，该函数在主线程的基础上创建一个新线程。线程终止运行后，线程对象仍然在系统中，必须通过CloseHandle函数来关闭该线程对象。函数原型如下
HANDLE CreateThread(
LPSECURITY_ATTRIBUTES lpThreadAttributes,//SD
SIZE_T dwStackSize,//initialstacksize
LPTHREAD_START_ROUTINE lpStartAddress,//threadfunction
LPVOID lpParameter,//threadargument
DWORD dwCreationFlags,//creationoption
LPDWORD lpThreadId//threadidentifier
)
- 第一个参数 lpThreadAttributes 表示线程内核对象的安全属性，一般传入NULL表示使用默认设置。
- 第二个参数 dwStackSize 表示线程栈空间大小。传入0表示使用默认大小（1MB）。
- 第三个参数 lpStartAddress 表示新线程所执行的线程函数地址，多个线程可以使用同一个函数地址。
- 第四个参数 lpParameter 是传给线程函数的参数。
- 第五个参数 dwCreationFlags 指定额外的标志来控制线程的创建，为0表示线程创建之后立即就可以进行调度，如果为CREATE_SUSPENDED则表示线程创建后暂停运行，这样它就无法调度，直到调用ResumeThread()。
- 第六个参数 lpThreadId 将返回线程的ID号，传入NULL表示不需要返回该线程ID号
返回值 : // 成功返回新线程句柄， 失败返回0
_beginthreadex是对CreateThread函数的优化，使用方法基本一致。函数原型如下
unsigned long _beginthreadex(
void *security, // 安全属性， 为NULL时表示默认安全性
unsigned stack_size, // 线程的堆栈大小， 一般默认为0
unsigned(_stdcall *start_address)(void *), // 线程函数
void *argilist, // 线程函数的参数
unsigned initflag, // 新线程的初始状态，0表示立即执行，//CREATE_SUSPENDED表示创建之后挂起
unsigned *threaddr // 用来接收线程ID
);
返回值 : // 成功返回新线程句柄， 失败返回0
等待函数 WaitForSingleObject 和 WaitForMultipleObjects
函数功能：等待函数 – 使线程进入等待状态，直到指定的内核对象被触发。函数原型如下
DWORDWINAPIWaitForSingleObject(
HANDLEhHandle,
DWORDdwMilliseconds
);
函数说明：
第一个参数为要等待的内核对象。
第二个参数为最长等待的时间，以毫秒为单位，如传入5000就表示5秒，传入0就立即返回，传入INFINITE表示无限等待。
因为线程的句柄在线程运行时是未触发的，线程结束运行，句柄处于触发状态。所以可以用WaitForSingleObject()来等待一个线程结束运行。
函数返回值：
在指定的时间内对象被触发，函数返回WAIT_OBJECT_0。超过最长等待时间对象仍未被触发返回WAIT_TIMEOUT。传入参数有错误将返回WAIT_FAILED
WaitForMultipleObjects(
_In_DWORD nCount, // 要监测的句柄的组的句柄的个数
_In_reads_(nCount) CONSTHANDLE* lpHandles, //要监测的句柄的组
_In_BOOL bWaitAll, // TRUE 等待所有的内核对象发出信号， FALSE 任意一个内核对象发出信号
_In_DWORD dwMilliseconds //等待时间
);
例程代码
#include <stdio.h>
#include <windows.h>
#include <process.h>
unsigned int WINAPI ThreadFun(LPVOID p)
{
int cnt = *((int*)p);
for (int i = 0; i < cnt; i++)
{
Sleep(1000);
puts("running thread");
}
return 0;
}
int main()
{
printf("main begin\n");
int iParam = 5;
unsigned int dwThreadID;
DWORD wr;
HANDLE hThread = (HANDLE)_beginthreadex(NULL, 0, ThreadFun,
(void*)&iParam, 0, &dwThreadID);
if (hThread == NULL)
{
puts("_beginthreadex() error");
return -1;
}
//
printf("WaitForSingleObject begin\n");
if ((wr = WaitForSingleObject(hThread, INFINITE)) == WAIT_FAILED)
{
puts("thread wait error");
return -1;
}
printf("WaitForSingleObject end\n");
printf("main end\n");
system("pause");
return 0;
}
二 线程同步
互斥对象
互斥对象使用
(mutex)属于内核对象，它能够确保线程拥有对单个资源的互斥访问权。
互斥对象包含一个使用数量，一个线程ID和一个计数器。其中线程ID用于标识系统中的哪个线程当前拥有互斥对象，计数器用于指明该线程拥有互斥对象的次数。
创建互斥对象：调用函数CreateMutex。调用成功，该函数返回所创建的互斥对象的句柄。
请求互斥对象所有权：调用函数WaitForSingleObject函数。线程必须主动请求共享对象的所有权才能获得所有权。
释放指定互斥对象的所有权：调用ReleaseMutex函数。线程访问共享资源结束后，线程要主动释放对互斥对象的所有权，使该对象处于已通知状态。
CreateMutex函数原型
HANDLE WINAPI CreateMutexW(
_In_opt_LPSECURITY_ATTRIBUTES lpMutexAttributes, //指向安全属性
_In_BOOL bInitialOwner, //初始化互斥对象的所有者 TRUE 立即拥有互斥体，false表示创建的这个mutex不属于任何线程；所以处于激发状态，也就是有信号状态
_In_opt_LPCWSTR lpName //指向互斥对象名的指针 L“Bingo”
);
例程代码
#include <stdio.h>
#include <windows.h>
#include <process.h>
#define NUM_THREAD 50
unsigned WINAPI threadInc(void * arg);
unsigned WINAPI threadDes(void * arg);
long long num=0;
HANDLE hMutex;
int main(int argc, char *argv[])
{
HANDLE tHandles[NUM_THREAD];
int i;
hMutex=CreateMutex(NULL, FALSE, NULL);
for(i=0; i<NUM_THREAD; i++)
{
if(i%2)
tHandles[i]=(HANDLE)_beginthreadex(NULL, 0, threadInc, NULL, 0, NULL);
else
tHandles[i]=(HANDLE)_beginthreadex(NULL, 0, threadDes, NULL, 0, NULL);
}
WaitForMultipleObjects(NUM_THREAD, tHandles, TRUE, INFINITE);
CloseHandle(hMutex);
printf("result: %lld \n", num);
return 0;
}
unsigned WINAPI threadInc(void * arg)
{
int i;
WaitForSingleObject(hMutex, INFINITE);
for(i=0; i<500000; i++)
num+=1;
ReleaseMutex(hMutex);
return 0;
}
unsigned WINAPI threadDes(void * arg)
{
int i;
WaitForSingleObject(hMutex, INFINITE);
for(i=0; i<500000; i++)
num-=1;
ReleaseMutex(hMutex);
return 0;
}
事件对象
事件对象的使用
事件对象也属于内核对象，它包含以下三个成员：
● 使用计数；
● 用于指明该事件是一个自动重置的事件还是一个人工重置的事件的布尔值；
● 用于指明该事件处于已通知状态还是未通知状态的布尔值。
事件对象有两种类型：人工重置的事件对象和自动重置的事件对象。这两种事件对象的区别在于当人工重置的事件对象得到通知时，等待该事件对象的所有线程均变为可调度线程；而当一个自动重置的事件对象得到通知时，等待该事件对象的线程中只有一个线程变为可调度线程。
1. 创建事件对象
调用CreateEvent函数创建或打开一个命名的或匿名的事件对象。
2. 设置事件对象状态
调用SetEvent函数把指定的事件对象设置为有信号状态。
3. 重置事件对象状态
调用ResetEvent函数把指定的事件对象设置为无信号状态。
4. 请求事件对象
线程通过调用WaitForSingleObject函数请求事件对象。
函数原型
HANDLE CreateEvent(
LPSECURITY_ATTRIBUTES lpEventAttributes, // 安全属性
BOOL bManualReset, // 复位方式 TRUE 必须用ResetEvent手动复原 FALSE 自动还原为无信号状态BOOL bInitialState, // 初始状态 TRUE 初始状态为有信号状态 FALSE 无信号状态
LPCTSTR lpName //对象名称 NULL 无名的事件对象
);
例程代码
/*
输入一个全局字串： ABCD AAADDD
通过多线程的方式来判断有几个字母A，必须用线程同步的方式实现；
事件对象来实现：
*/
#include <stdio.h>
#include <windows.h>
#include <process.h>
#define STR_LEN 100
unsigned WINAPI NumberOfA(void* arg);
unsigned WINAPI NumberOfOthers(void* arg);
static char str[STR_LEN];
static HANDLE hEvent;
int main(int argc, char* argv[])
{
HANDLE hThread1, hThread2;
fputs("Input string: ", stdout);
fgets(str, STR_LEN, stdin);
//NUll 默认的安全符 手动 FALSE 初始状态为无信号状态
hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);
hThread1 = (HANDLE)_beginthreadex(NULL, 0, NumberOfA, NULL, 0, NULL);
hThread2 = (HANDLE)_beginthreadex(NULL, 0, NumberOfOthers, NULL, 0, NULL);
WaitForSingleObject(hThread1, INFINITE);
WaitForSingleObject(hThread2, INFINITE);
//直到2个线程执行完之后，再把事件设置为无信号状态
ResetEvent(hEvent);
CloseHandle(hEvent);
system("pause");
return 0;
}
unsigned WINAPI NumberOfA(void* arg)
{
int i, cnt = 0;
//再没有执行fputs("Input string: ", stdout);
//fgets(str, STR_LEN, stdin);SetEvent(hEvent);之前，卡在
//WaitForSingleObject
WaitForSingleObject(hEvent, INFINITE);
for (i = 0; str[i] != 0; i++)
{
if (str[i] == 'A')
cnt++;
}
printf("Num of A: %d \n", cnt);
return 0;
}
unsigned WINAPI NumberOfOthers(void* arg)
{
int i, cnt = 0;
//再没有执行fputs("Input string: ", stdout);
//fgets(str, STR_LEN, stdin);SetEvent(hEvent);之前，卡在
//WaitForSingleObject
// WaitForSingleObject(hEvent, INFINITE);
for (i = 0; str[i] != 0; i++)
{
if (str[i] != 'A')
cnt++;
}
printf("Num of others: %d \n", cnt - 1);
//把事件对象设置为有信号状态
SetEvent(hEvent);
return 0;
}
关键代码段-（临界区）
关键代码段的使用
关键代码段，也称为临界区，工作在用户方式下。它是指一个小代码段，在代码能够执行前，它必须独占对某些资源的访问权。通常把多线程中访问同一种资源的那部分代码当做关键代码段。
初始化关键代码段-调用InitializeCriticalSection函数初始化一个关键代码段。
InitializeCriticalSection(
_Out_LPCRITICAL_SECTION lpCriticalSection
);
该函数只有一个指向CRITICAL_SECTION结构体的指针。在调用InitializeCriticalSection函数之前，首先需要构造一个CRITICAL_SECTION结构体类型的对象，然后将该对象的地址传递给InitializeCriticalSection函数。
进入关键代码段-调用EnterCriticalSection函数，以获得指定的临界区对象的所有权，该函数等待指定的临界区对象的所有权，如果该所有权赋予了调用线程，则该函数就返回；否则该函数会一直等待，从而导致线程等待。
退出关键代码段-线程使用完临界区所保护的资源之后，需要调用LeaveCriticalSection函数，释放指定的临界区对象的所有权。之后，其他想要获得该临界区对象所有权的线程就可以获得该所有权，从而进入关键代码段，访问保护的资源。
删除临界区-当临界区不再需要时，可以调用DeleteCriticalSection函数释放该对象，该函数将释放一个没有被任何线程所拥有的临界区对象的所有资源。
例程代码
#include <stdio.h>
#include <windows.h>
#include <process.h>
int iTickets = 5000;
CRITICAL_SECTION g_cs;
// A窗口 B窗口
DWORD WINAPI SellTicketA(void* lpParam)
{
while (1)
{
EnterCriticalSection(&g_cs);//进入临界区
if (iTickets > 0)
{
Sleep(1);
iTickets--;
printf("A remain %d\n", iTickets);
LeaveCriticalSection(&g_cs);//离开临界区
}
else
{
LeaveCriticalSection(&g_cs);//离开临界区
break;
}
}
return 0;
}
DWORD WINAPI SellTicketB(void* lpParam)
{
while (1)
{
EnterCriticalSection(&g_cs);//进入临界区
if (iTickets > 0)
{
Sleep(1);
iTickets--;
printf("B remain %d\n", iTickets);
LeaveCriticalSection(&g_cs);//离开临界区
}
else
{
LeaveCriticalSection(&g_cs);//离开临界区
break;
}
}
return 0;
}
int main()
{
HANDLE hThreadA, hThreadB;
hThreadA = CreateThread(NULL, 0, SellTicketA, NULL, 0, NULL); //2
hThreadB = CreateThread(NULL, 0, SellTicketB, NULL, 0, NULL); //2
CloseHandle(hThreadA); //1
CloseHandle(hThreadB); //1
InitializeCriticalSection(&g_cs); //初始化关键代码段
Sleep(40000);
DeleteCriticalSection(&g_cs);//删除临界区
system("pause");
return 0;
}
信号量 Semaphore
信号量详细介绍
-内核对象的状态：
触发状态(有信号状态)，表示有可用资源。
未触发状态（无信号状态），表示没有可用资源
-信号量的组成
①计数器：该内核对象被使用的次数
②最大资源数量：标识信号量可以控制的最大资源数量（带符号的32位）
③当前资源数量：标识当前可用资源的数量（带符号的32位）。即表示当前开放资源的个数（注意不是剩下资源的个数），只有开放的资源才能被线程所申请。但这些开放的资源不一定被线程占用完。比如，当前开放5个资源，而只有3个线程申请，则还有2个资源可被申请，但如果这时总共是7个线程要使用信号量，显然开放的资源5个是不够的。这时还可以再开放2个，直到达到最大资源数量。
信号量的规则如下：
（1）如果当前资源计数大于0，那么信号量处于触发状态(有信号状态)，表示有可用资源。
（2）如果当前资源计数等于0，那么信号量属于未触发状态（无信号状态），表示没有可用资源。
（3）系统绝对不会让当前资源计数变为负数
（4）当前资源计数绝对不会大于最大资源计数
信号量与互斥量不同的地方是，它允许多个线程在同一时刻访问同一资源，但是需要限制在同一时刻访问此资源的最大线程数目。信号量对象对线程的同步方式与前面几种方法不同，信号允许多个线程同时使用共享资源。
函数原型
创建信号量 CreateSemaphoreW
HANDLE WINAPI CreateSemaphoreW(
_In_opt_LPSECURITY_ATTRIBUTES lpSemaphoreAttributes, // Null 安全属性
_In_LONG lInitialCount, //初始化时，共有多少个资源是可以用的。 0：未触发状//态（无信号状态），表示没有可用资源
_In_LONG lMaximumCount, //能够处理的最大的资源数量
_In_opt_LPCWSTR lpName //NULL 信号量的名称
);
增加信号量 ReleaseSemaphore
WINAPI ReleaseSemaphore(
_In_HANDLE hSemaphore, //信号量的句柄
_In_LONG lReleaseCount, //将lReleaseCount值加到信号量的当前资源计数上面
_Out_opt_LPLONG lpPreviousCount //当前资源计数的原始值
);
例程代码
#include <stdio.h>
#include <windows.h>
#include <process.h>
unsigned WINAPI Read(void* arg);
unsigned WINAPI Accu(void* arg);
static HANDLE semOne;
static HANDLE semTwo;
static int num;
int main(int argc, char* argv[])
{
HANDLE hThread1, hThread2;
semOne = CreateSemaphore(NULL, 0, 1, NULL);
//semOne 没有可用资源 只能表示0或者1的二进制信号量 无信号
semTwo = CreateSemaphore(NULL, 1, 1, NULL);
//semTwo 有可用资源，有信号状态 有信号
hThread1 = (HANDLE)_beginthreadex(NULL, 0, Read, NULL, 0, NULL);
hThread2 = (HANDLE)_beginthreadex(NULL, 0, Accu, NULL, 0, NULL);
WaitForSingleObject(hThread1, INFINITE);
WaitForSingleObject(hThread2, INFINITE);
CloseHandle(semOne);
CloseHandle(semTwo);
system("pause");
return 0;
}
unsigned WINAPI Read(void* arg)
{
int i;
for (i = 0; i < 5; i++)
{
fputs("Input num: ", stdout); // 1 5 11
printf("begin read\n"); // 3 6 12
//等待内核对象semTwo的信号，如果有信号，继续执行；如果没有信号，等待
WaitForSingleObject(semTwo, INFINITE);
printf("beginning read\n"); //4 10 16
scanf("%d", &num);
ReleaseSemaphore(semOne, 1, NULL);
}
return 0;
}
unsigned WINAPI Accu(void* arg)
{
int sum = 0, i;
for (i = 0; i < 5; i++)
{
printf("begin Accu\n"); //2 9 15
//等待内核对象semOne的信号，如果有信号，继续执行；如果没有信号，等待
WaitForSingleObject(semOne, INFINITE);
printf("beginning Accu\n"); //7 13
sum += num;
printf("sum = %d \n", sum); // 8 14
ReleaseSemaphore(semTwo, 1, NULL);
}
printf("Result: %d \n", sum);
return 0;
}
线程同步的四种方式对比
比较 | 互斥量 Mutex | 事件对象 Event | 信号量对象 Semaphore | 关键代码段 Criticalsection |
是否为内核对象 | 是 | 是 | 是 | 否 |
速度 | 较慢 | 较慢 | 慢 | 快 |
多个进程中的线程同步 | 支持 | 支持 | 支持 | 不支持 |
发生死锁 | 否 | 否 | 否 | 是 |
组成 | 一个线程ID；用来标识哪个线程拥有该互斥量；一个计数器：用来知名该线程用于互斥对象的次数 | 一个使用计数；一个布尔值：用来标识该事件是自动重置还是人工重置；一个布尔值：标识该事件处于有信号状态还是无信号状态 | 一个使用计数； 最大资源数； 标识当前可用的资源数 | 一个小代码段； 在代码能够执行前，必须占用对某些资源的访问权 |
相关函数 | CreateMutex WaitForSingleObjects //被保护的内容 ReleaseMutex | CreateEvent ResetEvent WaitforSingleobject //保护内容 SetEvent | CreateSemaphore WaitForsingleobject //被保护的内容 ReleaseSemaPhore | InitialCriticalSection EnterCritionSection //被保护的内容 LeaveCritialSection DeleteCritialSection |
注意事项 | 谁拥有互斥对象，谁释放； 如果多次在同一个线程中请求同一个互斥对象，需要多次调用releaseMutex | 为了实现线程间的同步，不应该使用人工重置，应该把第二个参数设置false；设置为自动重置 | 它允许多个线程在同一时间访问同一个资源；但是需要限制访问此资源的最大线程数目； | 防止死锁：使用多个关键代码段变量的时候 |
类比 | 一把钥匙 | 钥匙（自动/人工） | 停车场和保安 | 电话亭 |
线程死锁
死锁是指多个线程因竞争资源而造成的一种僵局（互相等待），若无外力作用，这些进程都将无法向前推进。
使用关键代码段时，很容易进入死锁状态，因为在等待进入关键代码段时无法设定超时值
代码举例
#include <stdio.h>
#include <windows.h>
#include <process.h>
int iTickets = 5000;
CRITICAL_SECTION g_csA;
CRITICAL_SECTION g_csB;
// A窗口 B窗口
DWORD WINAPI SellTicketA(void* lpParam)
{
while (1)
{
EnterCriticalSection(&g_csA);//进入临界区A
Sleep(1);
EnterCriticalSection(&g_csB);//进入临界区B
if (iTickets > 0)
{
Sleep(1);
iTickets--;
printf("A remain %d\n", iTickets);
LeaveCriticalSection(&g_csB);//离开临界区B
LeaveCriticalSection(&g_csA);//离开临界区A
}
else
{
LeaveCriticalSection(&g_csB);//离开临界区B
LeaveCriticalSection(&g_csA);//离开临界区A
break;
}
}
return 0;
}
DWORD WINAPI SellTicketB(void* lpParam)
{
while (1)
{
EnterCriticalSection(&g_csB);//进入临界区B
Sleep(1);
EnterCriticalSection(&g_csA);//进入临界区A
if (iTickets > 0)
{
Sleep(1);
iTickets--;
printf("B remain %d\n", iTickets);
LeaveCriticalSection(&g_csA);//离开临界区A
LeaveCriticalSection(&g_csB);//离开临界区B
}
else
{
LeaveCriticalSection(&g_csA);//离开临界区A
LeaveCriticalSection(&g_csB);//离开临界区B
break;
}
}
return 0;
}
int main()
{
HANDLE hThreadA, hThreadB;
hThreadA = CreateThread(NULL, 0, SellTicketA, NULL, 0, NULL); //2
hThreadB = CreateThread(NULL, 0, SellTicketB, NULL, 0, NULL); //2
CloseHandle(hThreadA); //1
CloseHandle(hThreadB); //1
InitializeCriticalSection(&g_csA); //初始化关键代码段A
InitializeCriticalSection(&g_csB); //初始化关键代码段B
Sleep(40000);
DeleteCriticalSection(&g_csA);//删除临界区
DeleteCriticalSection(&g_csB);//删除临界区
system("pause");
return 0;
}
边栏推荐
- 学习笔记5--高精地图解决方案
- Unity粒子特效系列-毒液喷射预制体做好了，unitypackage包直接用 -下
- Swift saves an array of class objects with userdefaults and nssecurecoding
- TypeError: Cannot read properties of undefined (reading ‘cancelToken‘)
- pytorch输出tensor张量时有省略号的解决方案（将tensor完整输出）
- 如何獲取GC(垃圾回收器)的STW(暫停)時間?
- 请问postgresql cdc 怎么设置单独的增量模式呀，debezium.snapshot.mo
- Usage differences between isempty and isblank
- Swift uses userdefaults and codable to save an array of class objects or structure instances
- 宝塔面板MySQL无法启动
猜你喜欢
驱动制造业产业升级新思路的领域知识网络，什么来头？
AtCoder Beginner Contest 254「E bfs」「F st表维护差分数组gcd」
A large number of virtual anchors in station B were collectively forced to refund: revenue evaporated, but they still owe station B; Jobs was posthumously awarded the U.S. presidential medal of freedo
历史上的今天：第一本电子书问世；磁条卡的发明者出生；掌上电脑先驱诞生...
Coordinate system of view
Energy momentum: how to achieve carbon neutralization in the power industry?
Swift tableview style (I) system basic
Today in history: the first e-book came out; The inventor of magnetic stripe card was born; The pioneer of handheld computer was born
mongoDB副本集
Advanced opencv:bgr pixel intensity map
随机推荐
Advanced opencv:bgr pixel intensity map
一个程序员的职业生涯到底该怎么规划？
The essence of persuasion is to remove obstacles
学习笔记5--高精地图解决方案
Redis如何实现多可用区？
Interview: how does the list duplicate according to the attributes of the object?
Comment obtenir le temps STW du GC (collecteur d'ordures)?
【小技巧】获取matlab中cdfplot函数的x轴，y轴的数值
微信小程序中，从一个页面跳转到另一个页面后，在返回后发现页面同步滚动了
leetcode:1200. 最小绝对差
Applet image height adaptation and setting text line height
Have you learned to make money in Dingding, enterprise micro and Feishu?
Constrained layout flow
. Net delay queue
A high density 256 channel electrode cap for dry EEG
mongoDB副本集
ConstraintLayout的流式布局Flow
Lepton 无损压缩原理及性能分析
【JS】数组降维
天龙八部TLBB系列 - 关于技能冷却和攻击范围数量的问题