-
【正点原子I.MX6U-MINI应用篇】9、嵌入式Linux中的多线程编程pthread
一、线程的使用
1.1 为什么要使用多线程
在编写代码时，是否会遇到以下的场景会感觉到难以下手？
要做2件事，一件需要阻塞等待，另一件需要实时进行。例如播放器：一边在屏幕上播放视频，一边在等待用户的按键操作。如果使用单线程的话，程序必须一会查询有无按键，一会播放视频。查询按键太久，就会导致视频播放卡顿；视频播放太久，就无法及时响应用户的操作。并且查询按键和播放视频的代码混杂在一起，代码丑陋。如果使用多线程，线程 1 单独处理按键，线程 2 单独处理播放，可以完美解决上述问题。
1.2 线程概念
所谓线程，就是操作系统所能调度的最小单位。普通的进程，只有一个线程在执行对应的逻辑。我们可以通过多线程编程，使一个进程可以去执行多个不同的任务。相比多进程编程而言，线程享有共享资源，即在进程中出现的全局变量，每个线程都可以去访问它，与进程共享“4G”内存空间，使得系统资源消耗减少。
1.3 线程的标识pthread_t
对于进程而言，每一个进程都有一个唯一对应的PID号来表示该进程，而对于线程而言，也有一个类似于进程的 PID号，名为tid，其本质是一个pthread_t类型的变量。线程号与进程号是表示线程和进程的唯一标识，但是对于线程号而言，其仅仅在其所属的进程上下文中才有意义。
获取线程号
#includepthread_t pthread_self(void); //成功：返回线程号 - 1
- 2
- 3
在程序中，可以通过函数pthread_self，来返回当前线程的线程号。
测试例程1：（Phtread_txex2.1）
#include#include int main() { pthread_t tid = pthread_self(); printf("tid = %lu\n",(unsigned long)tid); return 0; } - 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text1 Pthread_Text1.c -lpthread- 1
编译结果：
1.4 线程的创建
怎么创建线程呢？使用pthread_create函数：
//创建线程 #includeint pthread_create(pthread_t *thread, const pthread_attr_t *attr,void *(*start_routi ne) (void *), void *arg); - 1
- 2
- 3
- 4
- 该函数第一个参数为pthread_t 指针，用来保存新建线程的线程号；
- 第二个参数表示了线程的属性，一般传入 NULL 表示默认属性；
- 第三个参数是一个函数指针，就是线程执行的函数。这个函数返回值为 void*，形参为 void*。
- 第四个参数则表示为向线程处理函数传入的参数，若不传入，可用 NULL 填充。
测试例程2：（Phtread_txex2.c）
#include#include #include #include void *fun(void *arg) { printf("pthread_New = %lu\n",(unsigned long)pthread_self()); } int main() { pthread_t tid1; int ret = pthread_create(&tid1,NULL,fun,NULL); if(ret != 0){ perror("pthread_create"); return -1; } /*tid_main 为通过pthread_self获取的线程ID，tid_new通过执行pthread_create成功后tid指向的空间*/ printf("tid_main = %lu tid_new = %lu \n",(unsigned long)pthread_self(),(unsigned long)tid1); /*因线程执行顺序随机，不加sleep可能导致猪线程先执行，导致进程结束，无法执行到子线程*/ sleep(1); 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text2 Pthread_Text2.c -lpthread- 1
编译结果：
通过pthread_create确实可以创建出来线程 ， 主线程中执行pthread_create后的tid指向了线程号空 间， 与子线程通过函数pthread_self 打印出来的线程号一致。
特别说明的是，当主线程伴随进程结束时，所创建出来的线程也会立即结束，不会继续执行。并且创建出来的线程的执行顺序是随机竞争的，并不能保证哪一个线程会先运行。可以将上述代码中 sleep函数进行注释，观察实验现象。
将上述代码中 sleep函数进行注释，将运行代码3次，其中有2次被进程结束，无法执行到子线程的逻辑，最后一次则执行到了子线程逻辑后结束的进程。如此可以说明，线程的执行顺序不受控制，且整个进程结束后所产生的线程也随之被释放，在后续内容中将会描述如何控制线程执行。
1.5 向线程传入参数
pthread_create()的最后一个参数的为
void*类型的数据，表示可以向线程传递一个void*数据类型的参数，线程的回调函数中可以获取该参数，例程3举例了如何向线程传入变量地址与变量值。测试例程 3：（Phtread_txex3.c）
#include#include #include #include void *fun1(void *arg) { printf("%s:arg = %d Addr = %p\n",__FUNCTION__,*(int *)arg,arg); } void *fun2(void *arg) { printf("%s:arg = %d Addr = %p\n",__FUNCTION__,(int)(long)arg,arg); } int main() { pthread_t tid1,tid2; int a = 50; int ret = pthread_create(&tid1,NULL,fun1,(void *)&a);//地址传递 if(ret != 0){ perror("pthread_create"); return -1; } ret = pthread_create(&tid2,NULL,fun2,(void *)(long)a);//值传递 if(ret != 0){ perror("pthread_create"); return -1; } sleep(1); printf("%s:a = %d Add = %p \n",__FUNCTION__,a,&a); 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text3 Pthread_Text3.c -lpthread- 1
编译结果：
本例程展示了如何利用线程创建函数的第四个参数向线程传入数据，举例了如何以地址的方式传入值、以变量的方式传入值，例程代码的21行，是将变量a先行取地址后，再次强制类型转化为 void后传入线程，线程处理的回调函数中，先将万能指针 void转化为 int*，再次取地址就可以获得该地址变量的值，其本质在于地址的传递。例程代码的 27 行，直接将 int 类型的变量强制转化为void进行传递（针对不同位数机器，指针对其字数不同，需要 int 转化为 long在转指针，否则可能会发生警告），在线程处理回调函数中，直接将 void数据转化为 int 类型即可，本质上是在传递变量a的值。上述两种方法均可得到所要的值，但是要注意其本质，一个为地址传递，一个为值的传递。当变量发生改变时候，传递地址后，该地址所对应的变量也会发生改变，但传入变量值的时候，即使地址指针所指的变量发生变化，但传入的为变量值，不会受到指针的指向的影响，实际项目中切记两者之间的区别。
下面的例程就说明了地址传递和值传递的区别，请注意！
测试例程 4：（Phtread_txex4.c）
#include#include #include #include void *fun1(void *arg) { while(1){ printf("%s:arg = %d Addr = %p\n",__FUNCTION__,*(int *)arg,arg); sleep(1); } } void *fun2(void *arg) { while(1){ printf("%s:arg = %d Addr = %p\n",__FUNCTION__,(int)(long)arg,arg); sleep(1); } } int main() { pthread_t tid1,tid2; int a = 50; int ret = pthread_create(&tid1,NULL,fun1,(void *)&a); if(ret != 0){ perror("pthread_create"); return -1; } sleep(1); ret = pthread_create(&tid2,NULL,fun2,(void *)(long)a); if(ret != 0){ perror("pthread_create"); return -1; } while(1){ a++; sleep(1); printf("%s:a = %d Add = %p \n",__FUNCTION__,a,&a); } 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text4 Pthread_Text4.c -lpthread- 1
编译结果：
上述例程讲述了如何向线程传递一个参数，在处理实际项目中，往往会遇到传递多个参数的问题，我们可以通过结构体来进行传递，解决此问题。下面的测试例程 5，说展示了通过结构体来进行参数传递。测试例程 5：（Phtread_txex5.c）
#include#include #include #include #include struct Stu{ int Id; char Name[32]; float Mark; }; void *fun1(void *arg) { struct Stu *tmp = (struct Stu *)arg; printf("%s:Id = %d Name = %s Mark = %.2f\n",__FUNCTION__,tmp->Id,tmp->Name,tmp->Mark); } int main() { pthread_t tid1,tid2; struct Stu stu; stu.Id = 10000; strcpy(stu.Name,"ZhangSan"); stu.Mark = 94.6; int ret = pthread_create(&tid1,NULL,fun1,(void *)&stu); if(ret != 0){ perror("pthread_create"); return -1; } printf("%s:Id = %d Name = %s Mark = %.2f\n",__FUNCTION__,stu.Id,stu.Name,stu.Mark); sleep(1); 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text5 Pthread_Text5.c -lpthread- 1
编译结果：
1.6 线程的退出与回收
线程的退出情况有三种：
-
第一种是进程结束，进程中所有的线程也会随之结束。
-
第二种是通过函数
pthread_exit来主动的退出线程。 -
第三种被其他线程调用
pthread_cancel来被动退出。
当线程结束后，主线程可以通过函数
pthread_join/pthread_tryjoin_np来回收线程的资源，并且获得线程结束后需要返回的数据。1.6.1 线程主动退出
pthread_exit函数原型如下：//线程主动退出 #includevoid pthread_exit(void *retval); - 1
- 2
- 3
pthread_exit函数为线程退出函数，在退出时候可以传递一个void*类型的数据带给主线程，若选择不传出数据，可将参数填充为 NULL。
1.6.2 线程被动退出
pthread_cancel函数原型如下：//线程被动退出，其他线程使用该函数让另一个线程退出 #includeint pthread_cancel(pthread_t thread); //成功：返回 0 - 1
- 2
- 3
- 4
该函数传入一个 tid 号，会强制退出该 tid 所指向的线程，若成功执行会返回 0。
1.6.3 线程资源回收(阻塞方式)
pthread_join函数原型如下：//线程资源回收（阻塞） #includeint pthread_join(pthread_t thread, void **retval); - 1
- 2
- 3
该函数为线程回收函数，默认状态为阻塞状态，直到成功回收线程后才返回。第一个参数为要回收线程的 tid 号，第二个参数为线程回收后接受线程传出的数据。
1.6.4 线程资源回收(非阻塞方式)
pthread_tryjoin_np函数原型如下：//线程资源回收（非阻塞） #define _GNU_SOURCE #includeint pthread_tryjoin_np(pthread_t thread, void **retval); - 1
- 2
- 3
- 4
该函数为非阻塞模式回收函数，通过返回值判断是否回收掉线程，成功回收则返回 0，其余参数与
pthread_join一致。测试例程 6：（Phtread_txex6.c）
#include#include #include #include void *fun1(void *arg) { static int tmp = 0;//必须要static修饰，否则pthread_join无法获取到正确值 //int tmp = 0; tmp = *(int *)arg; tmp+=100; printf("%s:Addr = %p tmp = %d\n",__FUNCTION__,&tmp,tmp); pthread_exit((void *)&tmp); } int main() { pthread_t tid1; int a = 50; void *Tmp = NULL; int ret = pthread_create(&tid1,NULL,fun1,(void *)&a); if(ret != 0){ perror("pthread_create"); return -1; } pthread_join(tid1,&Tmp); printf("%s:Addr = %p Val = %d\n",__FUNCTION__,Tmp,*(int *)Tmp); 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text6 Pthread_Text6.c -lpthread- 1
编译结果：
上述例程先通过23行将变量以地址的形式传入线程，在线程中做出了自加100的操作，当线程退出的时候通过线程传参，用
void*类型的数据通过pthread_join接受。此例程去掉了之前加入的sleep函数，原因是pthread_join函数具备阻塞的特性，直至成功收回掉线程后才会冲破阻塞，因此不需要靠考虑主线程会执行到30行结束进程的情况。特别要说明的是例程第8行，当变量从线程传出的时候，需要加static修饰，对生命周期做出延续，否则无法传出正确的变量值。测试例程 7：（Phtread_txex7.c）
#define _GNU_SOURCE #include#include #include #include void *fun(void *arg) { printf("Pthread:%d Come !\n",(int)(long)arg+1); pthread_exit(arg); } int main() { int ret,i,flag = 0; void *Tmp = NULL; pthread_t tid[3]; for(i = 0;i < 3;i++){ ret = pthread_create(&tid[i],NULL,fun,(void *)(long)i); if(ret != 0){ perror("pthread_create"); return -1; } } while(1){ for(i = 0;i <3;i++){ if(pthread_tryjoin_np(tid[i],&Tmp) == 0){ printf("Pthread : %d exit !\n",(int )(long )Tmp+1); flag++; } } if(flag >= 3) break; } 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text7 Pthread_Text7.c -lpthread- 1
编译结果：
例程7展示了如何使用非阻塞方式来回收线程，此外也展示了多个线程可以指向同一个回调函数的情况。例程 6 通过阻塞方式回收线程几乎规定了线程回收的顺序，若最先回收的线程未退出，则一直会被阻塞，导致后续先退出的线程无法及时的回收。通过函数pthread_tryjoin_np，使用非阻塞回收，线程可以根据退出先后顺序自由的进行资源的回收。
测试例程 8：（Phtread_txex8.c）
#define _GNU_SOURCE #include#include #include #include void *fun1(void *arg) { printf("Pthread:1 come!\n"); while(1){ sleep(1); } } void *fun2(void *arg) { printf("Pthread:2 come!\n"); pthread_cancel((pthread_t )(long)arg); pthread_exit(NULL); } int main() { int ret,i,flag = 0; void *Tmp = NULL; pthread_t tid[2]; ret = pthread_create(&tid[0],NULL,fun1,NULL); if(ret != 0){ perror("pthread_create"); return -1; } sleep(1); ret = pthread_create(&tid[1],NULL,fun2,(void *)tid[0]); if(ret != 0){ perror("pthread_create"); return -1; } while(1){ for(i = 0;i <2;i++){ if(pthread_tryjoin_np(tid[i],NULL) == 0){ printf("Pthread : %d exit !\n",i+1); flag++; } } if(flag >= 2) break; } 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text8 Pthread_Text8.c -lpthread- 1
编译结果：
例程 8 展示了如何利用pthread_cancel函数主动的将某个线程结束。27行与 33 行创建了线程，将第一个线程的线程号传参形式传入了第二个线程。第一个的线程执行死循环睡眠逻辑，理论上除非进程结束，其永远不会结束，但在第二个线程中调用了pthread_cancel函数，相当于向该线程发送一个退出的指令，导致线程被退出，最终资源被非阻塞回收掉。此例程要注意第 32 行的 sleep函数，一定要确保线程 1 先执行，因线程是无序执行，故加入该睡眠函数控制顺序，后续，会讲解通过加锁、信号量等手段来合理的控制线程的临界资源访问与线程执行顺序控制。二、线程的控制
2.1 多线程编临界资源访问
当线程在运行过程中，去操作公共资源，如全局变量的时候，可能会发生彼此“矛盾”现象。例如线程 1 企图想让变量自增，而线程 2 企图想要变量自减，两个线程存在互相竞争的关系导致变量永远处于一个“平衡状态”，两个线程互相竞争，线程 1 得到执行权后将变量自加，当线程 2 得到执行权后将变量自减，变量似乎永远在某个范围内浮动，无法到达期望数值，如例程 9 所示。
测试例程 9：（Phtread_txex9.c）
#define _GNU_SOURCE #include#include #include #include int Num = 0; void *fun1(void *arg) { while(Num < 3){ Num++; printf("%s:Num = %d\n",__FUNCTION__,Num); sleep(1); } pthread_exit(NULL); } void *fun2(void *arg) { while(Num > -3){ Num--; printf("%s:Num = %d\n",__FUNCTION__,Num); sleep(1); } pthread_exit(NULL); } int main() { int ret; pthread_t tid1,tid2; ret = pthread_create(&tid1,NULL,fun1,NULL); if(ret != 0){ perror("pthread_create"); return -1; } ret = pthread_create(&tid2,NULL,fun2,NULL); if(ret != 0){ perror("pthread_create"); return -1; } pthread_join(tid1,NULL); pthread_join(tid2,NULL); 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text9 Pthread_Text9.c -lpthread- 1
编译结果：
为了解决上述对临界资源的竞争问题，pthread 线程引出了互斥锁来解决临界资源访问。通过对临界资源加锁来保护资源只被单个线程操作，待操作结束后解锁，其余线程才可获得操作权。
2.2 互斥锁API简述
多个线程都要访问某个临界资源，比如某个全局变量时，需要互斥地访问：我访问时，你不能访问。可以使用以下函数进行互斥操作。
2.2.1 初始化互斥量
函数原型如下：
int pthread_mutex_init(phtread_mutex_t *mutex,const pthread_mutexattr_t *restrict attr);- 1
该函数初始化一个互斥量。第一个参数是该互斥量指针，第二个参数为控制互斥量的属性，一般为 NULL。当函数成功后会返回 0，代表初始化互斥量成功。
当然初始化互斥量也可以调用宏来快速初始化，代码如下：
pthread_mutex_t mutex = PTHREAD_MUTEX_INITALIZER;- 1
2.2.2 互斥量加锁/解锁
函数原型如下：
//互斥量加锁（阻塞）/ 解锁 #includeint pthread_mutex_lock(pthread_mutex_t *mutex); int pthread_mutex_unlock(pthread_mutex_t *mutex); //成功：返回 0 - 1
- 2
- 3
- 4
- 5
lock 函数与 unlock 函数分别为加锁解锁函数，只需要传入已经初始化好的pthread_mutex_t 互斥量指针。成功后会返回 0。当某一个线程获得了执行权后，执行 lock 函数，一旦加锁成功后，其余线程遇到 lock 函数时候会发生阻塞，直至获取资源的线程执行 unlock 函数后。unlock 函数会唤醒其他正在等待互斥量的线程。
特别注意的是，当获取 lock 之后，必须在逻辑处理结束后执行 unlock，否则会发生死锁现象！导致其余线程一直处于阻塞状态，无法执行下去。在使用互斥量的时候，尤其要注意使用 pthread_cancel 函数，防止发生死锁现象！
2.2.3 互斥量加锁( 非阻塞方式)
函数原型如下：
//互斥量加锁（非 阻塞） #includeint pthread_mutex_trylock(pthread_mutex_t *mutex); - 1
- 2
- 3
该函数同样也是一个线程加锁函数，但该函数是非阻塞模式通过返回值来判断是否加锁成功，用法与上述阻塞加锁函数一致。
2.2.4 互斥量加锁( 非阻塞方式)
函数原型如下：
//互斥量销毁 #includeint pthread_mutex_destory(pthread_mutex_t *mutex); //成功：返回 0 - 1
- 2
- 3
- 4
该函数是用于销毁互斥量的，传入互斥量的指针，就可以完成互斥量的销毁，成功返回 0。
测试例程 10：（Phtread_txex10.c）
#define _GNU_SOURCE #include#include #include #include pthread_mutex_t mutex; int Num = 0; void *fun1(void *arg) { pthread_mutex_lock(&mutex); while(Num < 3){ Num++; printf("%s:Num = %d\n",__FUNCTION__,Num); sleep(1); } pthread_mutex_unlock(&mutex); pthread_exit(NULL); } void *fun2(void *arg) { pthread_mutex_lock(&mutex); while(Num > -3){ Num--; printf("%s:Num = %d\n",__FUNCTION__,Num); sleep(1); } pthread_mutex_unlock(&mutex); pthread_exit(NULL); } int main() { int ret; pthread_t tid1,tid2; ret = pthread_mutex_init(&mutex,NULL); if(ret != 0){ perror("pthread_mutex_init"); return -1; } ret = pthread_create(&tid1,NULL,fun1,NULL); if(ret != 0){ perror("pthread_create"); return -1; } ret = pthread_create(&tid2,NULL,fun2,NULL); if(ret != 0){ perror("pthread_create"); return -1; } pthread_join(tid1,NULL); pthread_join(tid2,NULL); pthread_mutex_destroy(&mutex); 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text10 Pthread_Text10.c -lpthread- 1
编译结果：
上述例程通过加入互斥量，保证了临界变量某一时刻只被某一线程控制，实现了临界资源的控制。需要说明的是，线程加锁在循环内与循环外的情况。本例程在进入while循环前进行了加锁操作，在循环结束后进行的解锁操作，如果将加锁解锁全部放入while循环内，作为单核的机器，执行结果没啥不同，当有多核机器执行代码时，可能会发生“抢锁”现象，这取决于操作系统底层的实现。
2.3 多线程编执行顺序控制
解决了临界资源的访问，但似乎对线程的执行顺序无法得到控制，因线程都是无序执行，之前采用 sleep强行延时的方法勉强可以控制执行顺序，但此方法在实际项目情况往往是不可取的，其仅仅可解决线程创建的顺序，当创建之后执行的顺序又不会受到控制，于是便引入了信号量的概念，解决线程执行顺序。例程 11 将展示线程的执行的随机性。
测试例程 11：（Phtread_txex11.c）
#define _GNU_SOURCE #include#include #include #include void *fun1(void *arg) { printf("%s:Pthread Come!\n",__FUNCTION__); pthread_exit(NULL); } void *fun2(void *arg) { printf("%s:Pthread Come!\n",__FUNCTION__); pthread_exit(NULL); } void *fun3(void *arg) { printf("%s:Pthread Come!\n",__FUNCTION__); pthread_exit(NULL); } int main() { int ret; pthread_t tid1,tid2,tid3; ret = pthread_create(&tid1,NULL,fun1,NULL); if(ret != 0){ perror("pthread_create"); return -1; } ret = pthread_create(&tid2,NULL,fun2,NULL); if(ret != 0){ perror("pthread_create"); return -1; } ret = pthread_create(&tid3,NULL,fun3,NULL); if(ret != 0){ perror("pthread_create"); return -1; } pthread_join(tid1,NULL); pthread_join(tid2,NULL); pthread_join(tid3,NULL); 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text11 Pthread_Text11.c -lpthread- 1
编译结果：
通过上述例程可以发现，多次执行该函数其次序是无序的，线程之间的竞争无法控制，通过使用信号量来使得线程顺序为可控的。2.4 信号量API简述
注意：信号量跟互斥量不一样，互斥量用来防止多个线程同时访问某个临界资源。信号量起通知作用，线程A在等待某件事，线程B完成了这件事后就可以给线程A发信号。
2.4.1 初始化信号量
函数原型如下：
int sem_init(sem_t *sem,int pshared,unsigned int value);- 1
- 该函数可以初始化一个信号量，第一个参数传入 sem_t 类型指针；
- 第二个参数传入 0 代表线程控制，否则为进程控制；
- 第三个参数表示信号量的初始值，0 代表阻塞，1 代表运行。
- 待初始化结束信号量后，若执行成功会返回 0。
2.4.2 信号量申请与释放(P/V操作)
函数原型如下：
#includeint sem_wait(sem_t *sem); int sem_post(sem_t *sem); //成功：返回 0 - 1
- 2
- 3
- 4
-
sem_wait 函数作用为检测指定信号量是否有资源可用，若无资源可用会阻塞等待，若有资源可用会自动的执行
sem-1的操作。所谓的sem-1是与上述初始化函数中第三个参数值一致，成功执行会返回 0。 -
sem_post函数会释放指定信号量的资源，执行
sem+1操作。通过以上2个函数可以完成所谓的PV操作，即信号量的申请与释放，完成对线程执行顺序的控制。
2.4.3 信号量申请( 非阻塞方式)
函数原型如下：
#includeint sem_trywait(sem_t *sem); //成功：返回 0 - 1
- 2
- 3
此函数是信号量申请资源的非阻塞函数，功能与 sem_wait 一致，唯一区别在于此函数为非阻塞。
2.4.4 信号量销毁
函数原型如下：
#includeint sem_destory(sem_t *sem); //成功：返回 0 - 1
- 2
- 3
该函数为信号量销毁函数，执行过后可将信号量进行销毁。
测试例程 12：（Phtread_txex12.c）
#define _GNU_SOURCE #include#include #include #include #include sem_t sem1,sem2,sem3;//申请的三个信号量变量 void *fun1(void *arg) { sem_wait(&sem1);//因sem1本身有资源，所以不被阻塞 获取后sem1-1 下次会会阻塞 printf("%s:Pthread Come!\n",__FUNCTION__); sem_post(&sem2);// 使得sem2获取到资源 pthread_exit(NULL); } void *fun2(void *arg) { sem_wait(&sem2);//因sem2在初始化时无资源会被阻塞，直至14行代码执行 不被阻塞 sem2-1 下次会阻塞 printf("%s:Pthread Come!\n",__FUNCTION__); sem_post(&sem3);// 使得sem3获取到资源 pthread_exit(NULL); } void *fun3(void *arg) { sem_wait(&sem3);//因sem3在初始化时无资源会被阻塞，直至22行代码执行 不被阻塞 sem3-1 下次会阻塞 printf("%s:Pthread Come!\n",__FUNCTION__); sem_post(&sem1);// 使得sem1获取到资源 pthread_exit(NULL); } int main() { int ret; pthread_t tid1,tid2,tid3; ret = sem_init(&sem1,0,1); //初始化信号量1 并且赋予其资源 if(ret < 0){ perror("sem_init"); return -1; } ret = sem_init(&sem2,0,0); //初始化信号量2 让其阻塞 if(ret < 0){ perror("sem_init"); return -1; } ret = sem_init(&sem3,0,0); //初始化信号3 让其阻塞 if(ret < 0){ perror("sem_init"); return -1; } ret = pthread_create(&tid1,NULL,fun1,NULL);//创建线程1 if(ret != 0){ perror("pthread_create"); return -1; } ret = pthread_create(&tid2,NULL,fun2,NULL);//创建线程2 if(ret != 0){ perror("pthread_create"); return -1; } ret = pthread_create(&tid3,NULL,fun3,NULL);//创建线程3 if(ret != 0){ perror("pthread_create"); return -1; } /*回收线程资源*/ pthread_join(tid1,NULL); pthread_join(tid2,NULL); pthread_join(tid3,NULL); /*销毁信号量*/ sem_destroy(&sem1); sem_destroy(&sem2); sem_destroy(&sem3); 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
注意：因采用
POSIX线程接口，故在要编译的时候包含pthread库，使用gcc编译应gcc xxx.c -lpthread方可编译多线程程序。gcc -o Pthread_Text12 Pthread_Text12.c -lpthread- 1
编译结果：
该例程加入了信号量，使得线程的执行顺序变为可控的。在初始化信号量时，将信号量1填入资源，第一个线程调用sem_wait函数可以成功获得信号量，在执行完逻辑后使用
sem_pos函数来释放。当执行函数sem_wait后，会执行sem自减操作，使下一次竞争被阻塞，直至通过sem_pos被释放。上述例程因38行初始化信号量1时候，使其默认获取到资源；第43、48行初始化信号量2、3时候，使之没有资源。于是在线程处理函数中，每个线程通过sem_wait函数来等待资源，发生阻塞。因信号量1初始值为有资源，故可以先执行线程 1 的逻辑。待执行完第12行sem_wait函数，会导致sem1-1，使得下一次此线程会被阻塞。继而执行至14行，通过sem_post函数使sem2信号量获取资源，从而冲破阻塞执行线程 2 的逻辑…以此类推完成线程的有序控制。
三、总结
3.1 线程使用流程图
有关多线程的创建流程如图所示，首先需要创建线程，一旦线程创建完成后，线程与线程之间会发生竞争执行，抢占时间片来执行线程逻辑。在创建线程时候，可以通过创建线程的第四个参数传入参数，在线程退出时亦可传出参数被线程回收函数所回收，获取到传出的参数。
互斥量使用流程图
当多个线程出现后，会遇到同时操作临界公共资源的问题，当线程操作公共资源时需要对线程进行保护加锁，防止其与线程在此线程更改变量时同时更改变量，待逻辑执行完毕后再次解锁，使其余线程再度开始竞争。互斥锁创建流程下图所示。
信号量使用流程图
当多个线程出现后，同时会遇到无序执行的问题。有时候需要对线程的执行顺序做出限定，变引入了信号量，通过PV操作来控制线程的执行顺序，如下图所示。
-
相关阅读:
openEuler 知：abi 检测
html页面提交数据后，数据库有新增但为空值
一个爬虫自动化数据采集的故事~
酒水商城|基于Springboot实现酒水商城系统
【单目3D目标检测】SMOKE + MonoFlex 论文解析与代码复现
cesium示例教程100+目录
【python3】6.pickle json 序列化
GameFrameWork框架(Unity3D)使用笔记(六）游戏主流程ProcedureMain——从数据表加载出所需实体
从原理聊JVM（三）：详解现代垃圾回收器Shenandoah和ZGC
【Git】IDEA 集成 Git
- 原文地址：https://blog.csdn.net/qq_39400113/article/details/127677767
