• Linux多线程概念及实现

    目录

    一.Linux线程基本概念

    1.什么是线程

    2.页表的映射

    3.线程优点

    4.线程缺点

    5.线程异常

    6.线程用途

    二.Linux线程vs进程

    1.线程和进程

    2.进程的多个线程共享资源

    3.进程和线程的关系图          

    三.Linux线程控制 

    1.POSIX线程库

    2.线程创建

    3.线程等待

    4.线程终止

    5.线程分离

    6.线程ID的深入理解

     

    一.Linux线程基本概念

    1.什么是线程

    • 在一个程序里的一个执行路线就叫做线程（thread）。更准确的定义是：线程是“一个进程内部的控制序列”。
    • 一切进程至少都有一个执行线程。
    • 线程在进程内部运行，本质是在进程地址空间内运行。
    • 在Linux系统中，在CPU眼中，看到的PCB都要比传统的进程更轻量化。
    • 透过进程虚拟地址空间，可以看到进程的大部分资源，将进程资源合理分配给每个执行流，就形成了线程执行流。

                             

    (1)进程和线程

    • 创建一个进程需要一堆数据结构, 进程控制块（task_struct）、进程地址空间（mm_struct）以及页表的创建，虚拟地址和物理地址就是通过页表建立映射的。
    • 每个进程都有自己独立的进程地址空间和独立的页表，也就意味着所有进程在运行时本身就具有独立性。
    • 但如果我们在创建“进程”时，只创建task_struct，并要求创建出来的task_struct和父task_struct共享进程地址空间和页表

    理解:

    • 其中每一个线程都是当前进程里面的一个执行流，也就是我们常说的“线程是进程内部的一个执行分支”。
    • 同时我们也可以看出，线程在进程内部运行，本质就是线程在进程地址空间内运行，也就是说曾经这个进程申请的所有资源，几乎都是被所有线程共享的。
    • 进程独立和线程共享是相对的
    • 线程是进程内独立的执行分支

     

    (2)如何理解之前的进程 

     蓝色部分括起来的整体叫进程

    • 因此，所谓的进程并不是通过task_struct来衡量的，除了task_struct之外，一个进程还要有进程地址空间、文件、信号等等，合起来称之为一个进程。
    • 站在内核角度来理解进程：承担分配系统资源的基本实体，叫做进程。
    • 地址空间只有一个PCB,我就认为他是具有单执行流的进程 ; 地址空间具有多个PCB，我就认为它是具有多个执行流的进程。
    • 以前我们看到100个PCB就认为挂靠的有100个地址空间有页表，代码，数据等等都是不一样的  ;  现在我们看到的1个PCB，这个PCB背后挂靠的可能是和别人共享的地址空间，它只会使用地址空间的一部分.
       

    (3)在Linux中，站在CPU的角度，能否识别当前调度的task_struct是进程还是线程？

    •  不能，也不需要了，因为CPU只关心一个一个的独立执行流。无论进程内部只有一个执行流还是有多个执行流，CPU都是以task_struct为单位进行调度的。
    • Linux中所有的PCB(执行流) ， 可以看成轻量级进程 ；CPU看到的虽然还是task_struct，但已经比传统的进程要更轻量化了

    单执行流:

    多执行流: 

    (4)Linux下并不存在真正的多线程！而是用进程模拟的！ 

    • 操作系统中存在大量的进程，一个进程内又存在一个或多个线程，因此线程的数量一定比进程的数量多，当线程的数量足够多的时候，很明显线程的执行粒度要比进程更细。
    • 如果一款操作系统要支持真的线程，那么就需要对这些线程进行管理。比如说创建线程、终止线程、调度线程、切换线程、给线程分配资源、释放资源以及回收资源等等，所有的这一套相比较进程都需要另起炉灶，搭建一套与进程平行的线程管理模块。
    • 因此，如果要支持真的线程一定会提高设计操作系统的复杂程度。在Linux看来，描述线程的控制块和描述进程的控制块是类似的，因此Linux并没有重新为线程设计数据结构，而是依旧使用task_struct模拟线程，所以我们说Linux中的所有执行流都叫做轻量级进程。
    • 但也有支持真的线程的操作系统，比如Windows操作系统,有TCB，因此Windows操作系统系统的实现逻辑一定比Linux操作系统的实现逻辑要复杂得多。
       

    (5)Linux没有真正意义的线程，那么也就绝对没有真正意义上的线程相关的系统调用！ 

    • Linux提供了创建轻量级进程的接口，也就是创建进程，共享空间，其中最典型的代表就是vfork函数。 
    • vfork函数的功能就是创建子进程，但是父子共享空间
    pid_t vfork(void);

    vfork函数的返回值与fork函数的返回值相同：

    • 给父进程返回子进程的PID。
    • 给子进程返回0。

                    

    (6)关于原生线程库pthread 

    • 在Linux中，站在内核角度没有真正意义上线程相关的接口，但是站在用户角度，当用户想创建一个线程时更期望使用thread_create这样类似的接口，而不是vfork函数，因此系统为用户层提供了原生线程库pthread。
    • 原生线程库实际就是系统编写者对轻量级进程的系统调用进行了封装，通过在用户层模拟实现了一套线程相关的接口。
    • 因此对于我们来讲，在Linux下学习线程实际上就是学习在用户层模拟实现的这一套接口，而并非操作系统的接口。
       

                             

    2.页表的映射

    (1) 在32位平台下一共有2^32个地址，也就意味着有2^32个地址需要被映射。

     

                                     

     (2)每一个表项中除了要有虚拟地址和与其映射的物理地址以外，实际还需要有一些权限相关的信息，比如我们所说的用户级页表和内核级页表，实际就是通过权限进行区分的。

    • 每个应表项中存储一个物理地址和一个虚拟地址就需要8个字节，考虑到还需要包含权限相关的各种信息，这里每一个表项就按10个字节计算。
    • 这里一共有2^32个表项，也就意味着存储这张页表我们需要用2^32 * 10个字节，也就是40GB。而在32位平台下我们的内存可能一共就只有4GB，也就是说我们根本无法存储这样的一张页表。
       

                             

    (3)二级页表

    ①以32位平台为例，其页表的映射过程如下：

    • 选择虚拟地址的前10个比特位在页目录当中进行查找，找到对应的页表。
    • 再选择虚拟地址的10个比特位在对应的页表当中进行查找，找到物理内存中对应页框的起始地址。
    • 最后将虚拟地址中剩下的12个比特位作为偏移量从对应页框的起始地址处向后进行偏移，找到物理内存中某一个对应的字节数据。

                             

    ②相关说明：

    • 物理内存实际是被划分成一个个4KB大小的页框的，而磁盘上的程序也是被划分成一个个4KB大小的页帧的，当内存和磁盘进行数据交换时也就是以4KB大小为单位进行加载和保存的。
    • 4KB = 2^12个字节，一个页框中有2^12个字节，而访问内存的基本大小是1字节，因此一个页框中就有2^12个地址，于是我们就可以将剩下的12个比特位作为偏移量，从页框的起始地址处开始向后进行偏移，从而找到物理内存中某一个对应字节数据。

                    

    ③补充

    • 这实际上就是我们所谓的二级页表，其中页目录项是一级页表，页表项是二级页表。
    • 每一个表项还是按10字节计算，页目录和页表的表项都是2^10个，因此一个表的大小就是2^10 * 10个字节，也就是10KB。而页目录有2^10个表项也就意味着页表有2^10个，也就是说一级页表有1张，二级页表有2^10张，总共算下来大概就是10MB，内存消耗并不高，因此Linux中实际就是这样映射的。
    • 上面所说的所有映射过程，都是由MMU（MemoryManagementUnit）这个硬件完成的，该硬件是集成在CPU内的。页表是一种软件映射，MMU是一种硬件映射，所以计算机进行虚拟地址到物理地址的转化采用的是软硬件结合的方式。

    注意： 在Linux中，32位平台下用的是二级页表，而64位平台下用的是多级页表。

                    

    (4)修改常量字符串为什么会触发段错误

    1. char* msg = "hello bit\n";
    2. *msg = 'H';

    hellobit字符串—定是在内存中存的，但是msg地址用的是虚拟地址，访问hellobit的时候相当于你自己对应的指针变量是在栈区保存的临时变量，地址是虚拟地址，一定要经过页表的映射，字符常量区映射后也一定会找到物理内存  ;  通过msg指针变量访问虚拟地址，经过转换成物理地址，必须有个查表的过程，查找的时候发现映射到的目标区域权限是只R的，你要进行读取没问题，但是你要进行w，mmu内部触发硬件错误，被OS识别到是这个进程导致的错误，立马发信号终止错误

                            

    3.线程优点

    • 创建一个新线程的代价要比创建一个新进程小得多。

    • 与进程之间的切换相比，线程之间的切换需要操作系统做的工作要少很多(不需要切换地址空间和页表)

    • 线程占用的资源要比进程少很多。

    • 能充分利用多处理器的可并行数量。

    • 在等待慢速IO操作结束的同时，程序可执行其他的计算任务。

    • 计算密集型应用，为了能在多处理器系统上运行，将计算分解到多个线程中实现。

    • IO密集型应用，为了提高性能，将IO操作重叠，线程可以同时等待不同的IO操作

    • 计算密集型：执行流的大部分任务，主要以计算为主。比如加密解密、排序查找等。

    • IO密集型：执行流的大部分任务，主要以IO为主。比如刷磁盘、访问数据库、访问网络等。

                             

    4.线程缺点

    • 性能损失： 一个很少被外部事件阻塞的计算密集型线程往往无法与其他线程共享同一个处理器。如果计算密集型线程的数量比可用的处理器多，那么可能会有较大的性能损失，这里的性能损失指的是增加了额外的同步和调度开销，而可用的资源不变。
    • 健壮性降低： 编写多线程需要更全面更深入的考虑，在一个多线程程序里，因时间分配上的细微偏差或者因共享了不该共享的变量而造成不良影响的可能性是很大的，换句话说，线程之间是缺乏保护的。
    • 缺乏访问控制： 进程是访问控制的基本粒度，在一个线程中调用某些OS函数会对整个进程造成影响。
    • 编程难度提高： 编写与调试一个多线程程序比单线程程序困难得多。

                    

    5.线程异常

    • 单个线程如果出现除零、野指针等问题导致线程崩溃，进程也会随着崩溃。
    • 线程是进程的执行分支，线程出异常，就类似进程出异常，进而触发信号机制，终止进程，进程终止，该进程内的所有线程也就随即退出。

                    

    6.线程用途

    • 合理的使用多线程，能提高CPU密集型程序的执行效率。
    • 合理的使用多线程，能提高IO密集型程序的用户体验（如生活中我们一边写代码一边下载开发工具，就是多线程运行的一种表现）。

    二.Linux线程vs进程

    1.线程和进程

    ①进程是承担分配系统资源的基本实体，线程是调度的基本单位。

    ②进程更强调独立，线程更强调共享，但都不是绝对的

    ③线程共享进程数据，但也拥有自己的一部分数据：

    • 线程ID。
    • 一组寄存器（每个线程都有硬件上下文, 线程切换的时候用于信息保存）
    • 栈（私有运行栈，防止线程间数据干扰）
    • errno（C语言提供的全局变量，每个线程都有自己的）
    • 信号屏蔽字
    • 调度优先级
       

    2.进程的多个线程共享资源

    ①共用一个地址空间，因此所谓的代码段（Text Segment）、数据段（Data Segment）都是共享的：

    • 如果定义一个函数，在各线程中都可以调用。
    • 如果定义一个全局变量，在各线程中都可以访问到。

    ②除此之外，各线程还共享以下进程资源和环境：

    • 文件描述符表。（进程打开一个文件后，其他线程也能够看到）
    • 每种信号的处理方式。（SIG_IGN、SIG_DFL或者自定义的信号处理函数）
    • 当前工作目录。（cwd）
    • 用户ID和组ID。

                     

    3.进程和线程的关系图

                    

                    

                    

    三.Linux线程控制 

    1.POSIX线程库

    (1)pthread线程库是应用层的原生线程库：

    • 应用层指的是这个线程库并不是系统接口直接提供的，而是由第三方帮我们提供的。
    • 原生指的是大部分Linux系统都会默认带上该线程库。
    • 与线程有关的函数构成了一个完整的系列，绝大多数函数的名字都是以“pthread_”打头的。
    • 要使用这些函数库，要通过引入头文件<pthreaad.h>。
    • 链接这些线程函数库时，要使用编译器命令的“-l pthread”选项。

                     

    (2)错误检查：

    • 传统的一些函数是，成功返回0，失败返回-1，并且对全局变量errno赋值以指示错误。
    • pthreads函数出错时不会设置全局变量errno（而大部分POSIX函数会这样做），而是将错误代码通过返回值返回。
    • pthreads同样也提供了线程内的errno变量，以支持其他使用errno的代码。对于pthreads函数的错误，建议通过返回值来判定，因为读取返回值要比读取线程内的errno变量的开销更小。
    • C语言中errno是个全局变量，线程很可能有多个，大家用一个errno，这个errno就成了临界资源，在实际使用中就不安全了，所以我们最好每个线程一个错误码，就直接返回了。
       

                     

    2.线程创建

    函数原型：

    int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine) (void *), void *arg);

    参数：

    thread：获取创建成功的线程ID，该参数是一个输出型参数。
    attr：用于设置创建线程的属性，传入NULL表示使用默认属性。
    start_routine：该参数是一个函数地址，表示线程例程，即线程启动后要执行的函数。
    arg：传给线程例程的参数。

    返回值说明：

    线程创建成功返回0，失败返回错误码。

    (1)只创建一个线程

    ①代码示例

    1. #include <stdio.h>
    2. #include <pthread.h>
    3. #include <unistd.h>
    4.  
    5. void* Routine(void* arg)
    6. {
    7. 	char* msg = (char*)arg;
    8. 	while (1){
    9. 		printf("I am %s\n", msg);
    10. 		sleep(1);
    11. 	}
    12. }
    13.  
    14. int main()
    15. {
    16. 	pthread_t tid;
    17. 	pthread_create(&tid, NULL, Routine, (void*)"thread 1");
    18.  
    19. 	while (1){
    20. 		printf("I am main!\n");
    21. 		sleep(2);
    22. 	}
    23.  
    24. 	return 0;
    25. }

                     

    ②结果

                     

    ③ps命令查看详细信息 , ps -aL

    • 默认情况下，不带-L，看到的就是一个个的进程。
    • 带-L就可以查看到每个进程内的多个轻量级进程。

    •  LWP（Light Weight Process）就是轻量级进程的ID，可以看到两个轻量级进程的PID是相同的，所以它们属于同一个进程。
    • 之前说的OS调度—个进程，可以认为成单进程单执行流中,它调度的基本单位看的是pid也可以是LWP，因为他俩相等。现在我们认为线程调度时OS看的id是LWP。
    • LWP和PID的关系?        PID起的是对进程的标识作用，相同的进程具有相同的PID。LWP标识轻量级进程，他们的标识是不同的。OS真正调度的时候使用的是LWP。

                            

    (2)创建一批线程

    ①代码 : 让创建的每一个新线程都去执行Routine函数，Routine函数会被重复进入，即该函数是会被重入的。

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <pthread.h>
    4. #include <unistd.h>
    5. #include <sys/types.h>
    6.  
    7. void* Routine(void* arg)
    8. {
    9. 	char* msg = (char*)arg;
    10. 	while (1){
    11. 		printf("I am %s...pid: %d, ppid: %d\n", msg, getpid(), getppid());
    12. 		sleep(1);
    13. 	}
    14. }
    15.  
    16. int main()
    17. {
    18. 	pthread_t tid[5];
    19. 	for (int i = 0; i < 5; i++){
    20. 		char* buffer = (char*)malloc(64);
    21. 		sprintf(buffer, "thread %d", i); //格式化控制
    22. 		pthread_create(&tid[i], NULL, Routine, buffer);
    23. 	}
    24.  
    25. 	while (1){
    26. 		printf("I am main thread...pid: %d, ppid: %d\n", getpid(), getppid());
    27. 		sleep(2);
    28. 	}
    29.  
    30. 	return 0;
    31. }

                             

    ②结果

                            

    (3)获取线程ID  

    常见获取线程ID的方式有两种：

    • 创建线程时通过输出型参数获得。
    • 通过调用pthread_self函数获得。

    函数 : pthread_t pthread_self(void);
    调用pthread_self函数即可获得当前线程的ID，类似于调用getpid函数获取当前进程的ID。

                    

     ①代码 : 主线程都将通过输出型参数获取到的线程ID进行打印，此后主线程和新线程又通过调用pthread_self函数获取到自身的线程ID进行打印

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <pthread.h>
    4. #include <unistd.h>
    5. #include <sys/types.h>
    6.  
    7. void* Routine(void* arg)
    8. {
    9. 	char* msg = (char*)arg;
    10. 	while (1){
    11. 		printf("I am %s...pid: %d, ppid: %d, tid: %lu\n", msg, getpid(), getppid(), pthread_self());
    12. 		sleep(1);
    13. 	}
    14. }
    15.  
    16. int main()
    17. {
    18. 	pthread_t tid[5];
    19. 	for (int i = 0; i < 5; i++){
    20. 		char* buffer = (char*)malloc(64);
    21. 		sprintf(buffer, "thread %d", i);
    22. 		pthread_create(&tid[i], NULL, Routine, buffer);
    23. 		printf("%s tid is %lu\n", buffer, tid[i]);
    24. 	}
    25.  
    26. 	while (1){
    27. 		 printf("I am main thread...pid: %d, ppid: %d, tid: %lu\n", getpid(), getppid(), pthread_self());
    28. 		 sleep(2);
    29. 	}
    30. 	return 0;
    31. }

                             

    ②结果

    • 用pthread_self函数获得的线程ID与内核的LWP的值是不相等的，pthread_self函数获得的是用户级原生线程库的线程ID，而LWP是内核的轻量级进程ID，它们之间是1:1。

                     

    3.线程等待

    • 已经退出的线程，其空间没有被释放，仍然在进程的地址空间内。
    • 创建新的线程不会复用刚才退出线程的地址空间。
    • 一个线程被创建出来，这个线程就如同进程一般，也是需要被等待的。如果主线程不对新线程进行等待，那么这个新线程的资源也是不会被回收的。所以线程需要被等待，如果不等待会产生类似于“僵尸进程”的问题，也就是内存泄漏。

    函数：int pthread_join(pthread_t thread, void **retval);

    参数：

    • thread：被等待线程的ID。
    • retval：线程退出时的退出码信息。

    返回值说明：

    • 线程等待成功返回0，失败返回错误码。
    • 调用该函数的线程将阻塞式挂起等待，直到ID为thread的线程终止，thread线程以不同的方法终止，通过pthread_join得到的终止状态是不同的。

    总结 :

    • 如果thread线程通过return返回，retval所指向的单元里存放的是thread线程函数的返回值。
    • 如果thread线程被别的线程调用pthread_cancel异常终止掉，retval所指向的单元里存放的是常数PTHREAD_CANCELED。
    • 如果thread线程是自己调用pthread_exit终止的，retval所指向的单元存放的是传给pthread_exit的参数。
    • 如果对thread线程的终止状态不感兴趣，可以传NULL给retval参数。

     

     (1)获取线程的退出码

    ①代码

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <pthread.h>
    4. #include <unistd.h>
    5. #include <sys/types.h>
    6.  
    7. void* Routine(void* arg)
    8. {
    9. 	char* msg = (char*)arg;
    10. 	int count = 5;
    11. 	while (count--){
    12. 		printf("I am %s...pid: %d, ppid: %d, tid: %lu\n", msg, getpid(), getppid(), pthread_self());
    13. 		sleep(1);
    14. 	}
    15.  
    16. 	return (void*)101; 
    17. }
    18.  
    19.  
    20. int main()
    21. {
    22. 	pthread_t tid[5];
    23. 	for (int i = 0; i < 5; i++){
    24. 		char* buffer = (char*)malloc(64);
    25. 		sprintf(buffer, "thread %d", i);
    26. 		pthread_create(&tid[i], NULL, Routine, buffer);
    27. 		printf("%s tid is %lu\n", buffer, tid[i]);
    28. 	}
    29.  
    30. 	printf("I am main thread...pid: %d, ppid: %d, tid: %lu\n", getpid(), getppid(), pthread_self());
    31.  
    32. 	for (int i = 0; i < 5; i++){
    33. 		void* ret = NULL;
    34. 		pthread_join(tid[i], &ret);
    35. 		printf("thread %d[%lu]...quit, exitcode: %d\n", i, tid[i], (int)ret);
    36. 	}
    37. 	return 0;
    38. }

    ②结果

                            

    (2)线程退出拿到的退出码只能判断结果是否正确 

    ①pthread_join函数通过参数 retval拿到线程退出的退出码，只能判断代码运行完毕，结果是否正确. 

    ②难道不处理异常吗? 多线程不需要考虑异常？ 

    需要考虑，但是做不到！只要一个线程出了问题，整个进程就挂掉了，根本走不到join.

    ③某个线程崩溃了，整个进程也就跟着挂掉了，此时主线程连等待新线程的机会都没有，这也说明了多线程的健壮性不太强，一个进程中只要有一个线程挂掉了，那么整个进程就挂掉了。并且此时我们也不知道是由于哪一个线程崩溃导致的，我们只知道是这个进程崩溃了

                     

    4.线程终止

    (1)return 返回

    在线程中使用return代表当前线程退出，但是在main函数中使用return代表整个进程退出，也就是说只要主线程退出了那么整个进程就退出了，此时该进程曾经申请的资源就会被释放，而其他线程会因为没有了资源，自然而然的也退出了。

                     

    (2)pthread_exit函数

    pthread_exit函数的功能就是终止线程

    函数:  void pthread_exit(void *retval);


    参数： retval：线程退出时的退出码信息。


    说明一下：

    • 该函数无返回值，跟进程一样，线程结束的时候无法返回它的调用者（自身）。
    • pthread_exit或者return返回的指针所指向的内存单元必须是全局的或者是用malloc分配的，不能在线程函数的栈上分配，因为当其他线程得到这个返回指针时，线程函数已经退出了。
    • exit函数的作用是终止进程，任何一个线程调用exit函数也代表的是整个进程终止。

    ①代码

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <pthread.h>
    4. #include <unistd.h>
    5. #include <sys/types.h>
    6.  
    7. void* Routine(void* arg)
    8. {
    9. 	char* msg = (char*)arg;
    10. 	int count = 5;
    11. 	while (count--){
    12. 		printf("I am %s...pid: %d, ppid: %d, tid: %lu\n", msg, getpid(), getppid(), pthread_self());
    13. 		sleep(1);
    14. 	}
    15.  
    16.   pthread_exit((void*)101);
    17. }
    18.  
    19.  
    20. int main()
    21. {
    22. 	pthread_t tid[5];
    23. 	for (int i = 0; i < 5; i++){
    24. 		char* buffer = (char*)malloc(64);
    25. 		sprintf(buffer, "thread %d", i);
    26. 		pthread_create(&tid[i], NULL, Routine, buffer);
    27. 		printf("%s tid is %lu\n", buffer, tid[i]);
    28. 	}
    29.  
    30. 	printf("I am main thread...pid: %d, ppid: %d, tid: %lu\n", getpid(), getppid(), pthread_self());
    31.  
    32. 	for (int i = 0; i < 5; i++){
    33. 		void* ret = NULL;
    34. 		pthread_join(tid[i], &ret);
    35. 		printf("thread %d[%lu]...quit, exitcode: %d\n", i, tid[i], (int)ret);
    36. 	}
    37. 	return 0;
    38. }

    ②结果 

                     

    (3)pthread_cancel函数

    线程是可以被取消的，我们可以使用pthread_cancel函数取消某一个线程

    函数 :  int pthread_cancel(pthread_t thread);


    参数：thread：被取消线程的ID。


    返回值说明： 线程取消成功返回0，失败返回错误码。

    ①线程取消自己

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <pthread.h>
    4. #include <unistd.h>
    5. #include <sys/types.h>
    6.  
    7. void* Routine(void* arg)
    8. {
    9. 	char* msg = (char*)arg;
    10. 	int count = 0;
    11. 	while (count < 5){
    12. 		printf("I am %s...pid: %d, ppid: %d, tid: %lu\n", msg, getpid(), getppid(), pthread_self());
    13. 		sleep(1);
    14. 		count++;
    15. 		pthread_cancel(pthread_self());
    16. 	}
    17. 	pthread_exit((void*)101);
    18. }
    19.  
    20.  
    21. int main()
    22. {
    23. 	pthread_t tid[5];
    24. 	for (int i = 0; i < 5; i++){
    25. 		char* buffer = (char*)malloc(64);
    26. 		sprintf(buffer, "thread %d", i);
    27. 		pthread_create(&tid[i], NULL, Routine, buffer);
    28. 		printf("%s tid is %lu\n", buffer, tid[i]);
    29. 	}
    30.  
    31. 	printf("I am main thread...pid: %d, ppid: %d, tid: %lu\n", getpid(), getppid(), pthread_self());
    32.  
    33. 	for (int i = 0; i < 5; i++){
    34. 		void* ret = NULL;
    35. 		pthread_join(tid[i], &ret);
    36. 		printf("thread %d[%lu]...quit, exitcode: %d\n", i, tid[i], (int)ret);
    37. 	}
    38.  
    39. 	return 0;
    40. }

    每个线程执行一次打印操作后就退出了，其退出码不是101而是-1，因为我们是在线程执行pthread_exit函数前将线程取消的。

                     

     ②线程可以自己取消自己，但一般不这样做，我们往往是用于一个线程取消另一个线程

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <pthread.h>
    4. #include <unistd.h>
    5. #include <sys/types.h>
    6.  
    7. void* Routine(void* arg)
    8. {
    9. 	char* msg = (char*)arg;
    10. 	int count = 0;
    11. 	while (count < 3){
    12. 		printf("I am %s...pid: %d, ppid: %d, tid: %lu\n", msg, getpid(), getppid(), pthread_self());
    13. 		sleep(1);
    14. 		count++;
    15. 	}
    16. 	pthread_exit((void*)101);
    17. }
    18.  
    19. int main()
    20. {
    21. 	pthread_t tid[5];
    22. 	for (int i = 0; i < 5; i++){
    23. 		char* buffer = (char*)malloc(64);
    24. 		sprintf(buffer, "thread %d", i);
    25. 		pthread_create(&tid[i], NULL, Routine, buffer);
    26. 		printf("%s tid is %lu\n", buffer, tid[i]);
    27. 	}
    28.  
    29.  
    30. 	pthread_cancel(tid[0]); //取消两个线程
    31. 	pthread_cancel(tid[1]);
    32.  
    33. 	printf("I am main thread...pid: %d, ppid: %d, tid: %lu\n", getpid(), getppid(), pthread_self());
    34.  
    35. 	for (int i = 0; i < 5; i++){
    36. 		void* ret = NULL;
    37. 		pthread_join(tid[i], &ret);
    38. 		printf("thread %d[%lu]...quit, exitcode: %d\n", i, tid[i], (int)ret);
    39. 	}
    40.  
    41. 	return 0;
    42. }

                     

     ③新线程取消主线程

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <pthread.h>
    4. #include <unistd.h>
    5. #include <sys/types.h>
    6.  
    7. pthread_t main_thread;
    8.  
    9. void* Routine(void* arg)
    10. {
    11. 	char* msg = (char*)arg;
    12. 	int count = 0;
    13. 	while (count < 3){
    14. 		printf("I am %s...pid: %d, ppid: %d, tid: %lu\n", msg, getpid(), getppid(), pthread_self());
    15. 		sleep(1);
    16. 		count++;
    17. 		pthread_cancel(main_thread);
    18. 	}
    19. 	pthread_exit((void*)101);
    20. }
    21.  
    22. int main()
    23. {
    24. 	main_thread = pthread_self();
    25. 	pthread_t tid[5];
    26. 	for (int i = 0; i < 5; i++){
    27. 		char* buffer = (char*)malloc(64);
    28. 		sprintf(buffer, "thread %d", i);
    29. 		pthread_create(&tid[i], NULL, Routine, buffer);
    30. 		printf("%s tid is %lu\n", buffer, tid[i]);
    31. 	}
    32.  
    33. 	printf("I am main thread...pid: %d, ppid: %d, tid: %lu\n", getpid(), getppid(), pthread_self());
    34.  
    35. 	for (int i = 0; i < 5; i++){
    36. 		void* ret = NULL;
    37. 		pthread_join(tid[i], &ret);
    38. 		printf("thread %d[%lu]...quit, exitcode: %d\n", i, tid[i], (int)ret);
    39. 	}
    40.  
    41. 	return 0;
    42. }

    主线程右侧显示<default>，也就意味着主线程已经被取消了，我们也就看不到后续主线程等待新线程时打印的退出码了。

    注意：

    1. 当采用这种取消方式时，主线程和各个新线程之间的地位是对等的，取消一个线程，其他线程也是能够跑完的，只不过主线程不再执行后续代码了。
    2. 我们一般都是用主线程去控制新线程，这才符合我们对线程控制的基本逻辑，虽然实验表明新线程可以取消主线程，但是并不推荐该做法。

    5.线程分离

    (1)基本概念

    • 默认情况下，新创建的线程是joinable的，线程退出后，需要对其进行pthread_join操作，否则无法释放资源，从而造成内存泄漏。
    • 但如果我们不关心线程的返回值，join也是一种负担，此时我们可以将该线程进行分离，后续当线程退出时就会自动释放线程资源。
    • 一个线程如果被分离了，这个线程依旧要使用该进程的资源，依旧在该进程内运行，甚至这个线程崩溃了一定会影响其他线程，只不过这个线程退出时不再需要主线程去join了，当这个线程退出时系统会自动回收该线程所对应的资源。
    • 可以是线程组内其他线程对目标线程进行分离，也可以是线程自己分离。
    • joinable和分离是冲突的，一个线程不能既是joinable又是分离的。

                             

    (2)线程分离函数

    函数:  int pthread_detach(pthread_t thread)

    参数说明：thread：被分离线程的ID。

    返回值说明：  线程分离成功返回0，失败返回错误码

                             

    (3)使用示例

    ①代码

    1. #include <stdio.h>
    2. #include <stdlib.h>
    3. #include <pthread.h>
    4. #include <unistd.h>
    5. #include <sys/types.h>
    6.  
    7. void* Routine(void* arg)
    8. {
    9. 	pthread_detach(pthread_self()); //线程分离
    10. 	char* msg = (char*)arg;
    11. 	int count = 0;
    12. 	while (count < 3){
    13. 		printf("I am %s...pid: %d, ppid: %d, tid: %lu\n", msg, getpid(), getppid(), pthread_self());
    14. 		sleep(1);
    15. 		count++;
    16. 	}
    17. 	pthread_exit((void*)101);
    18. }
    19.  
    20. int main()
    21. {
    22. 	pthread_t tid[5];
    23. 	for (int i = 0; i < 5; i++){
    24. 		char* buffer = (char*)malloc(64);
    25. 		sprintf(buffer, "thread %d", i);
    26. 		pthread_create(&tid[i], NULL, Routine, buffer);
    27. 		printf("%s tid is %lu\n", buffer, tid[i]);
    28. 	}
    29.  
    30. 	while (1){
    31. 		printf("I am main thread...pid: %d, ppid: %d, tid: %lu\n", getpid(), getppid(), pthread_self());
    32. 		sleep(1);
    33. 	}
    34.  
    35. 	return 0;
    36. }

    ②结果

                    

    6.线程ID的深入理解

    (1)基本概念

    • thread_create函数会产生一个线程ID，存放在第一个参数指向的地址中，该线程ID和内核中的LWP不是一回事。

    • 内核中的LWP属于进程调度的范畴，因为线程是轻量级进程，是操作系统调度器的最小单位，所以需要一个数值来唯一表示该线程。

    • pthread_create函数第一个参数指向一个虚拟内存单元，该内存单元的地址即为新创建线程的线程ID，这个ID属于NPTL线程库的范畴，线程库的后续操作就是根据该线程ID来操作线程的。

    • 线程库NPTL提供的pthread_self函数，获取的线程ID和pthread_create函数第一个参数获取的线程ID是一样的。

                             

    (2)pthread_t类型

    ①Linux不提供真正的线程，只提供LWP，也就意味着操作系统只需要对内核执行流LWP进行管理，而供用户使用的线程接口等其他数据，应该由线程库自己来管理，因此管理线程时的“先描述，再组织”就应该在线程库里进行。

                     

    ②ldd命令查看线程库 , 线程库是一个动态库

                     

    ③通过地址空间理解 

    •  每个线程都有自己私有的栈，其中主线程采用的栈是进程地址空间中原生的栈，而其余线程采用的栈就是在共享区中开辟的。除此之外，每个线程都有自己的struct pthread，当中包含了对应线程的各种属性；每个线程还有自己的线程局部存储，当中包含了对应线程被切换时的上下文数据。
    • 每一个新线程在共享区都有这样一块区域对其进行描述，因此我们要找到一个用户级线程只需要找到该线程内存块的起始地址，然后就可以获取到该线程的各种信息。

    • 上面我们所用的各种线程函数，本质都是在库内部对线程属性进行的各种操作，最后将要执行的代码交给对应的内核级LWP去执行就行了，也就是说线程数据的管理本质是在共享区的。
    • pthread_t到底是什么类型取决于实现，但是对于Linux目前实现的NPTL线程库来说，线程ID本质就是进程地址空间共享区上的一个虚拟地址，同一个进程中所有的虚拟地址都是不同的，因此可以用它来唯一区分每一个线程。
    • 所谓线程ID可以理解为每个新线程在库当中的内存位置的起始地址，线程控制块的起始地址。
       

                     

    ④以地址的形式打印线程ID 

    1. #include <stdio.h>
    2. #include <pthread.h>
    3. #include <unistd.h>
    4.  
    5. void* Routine(void* arg)
    6. {
    7. 	while (1){
    8. 		printf("new  thread tid: %p\n", pthread_self());
    9. 		sleep(1);
    10. 	}
    11. }
    12.  
    13. int main()
    14. {
    15. 	pthread_t tid;
    16. 	pthread_create(&tid, NULL, Routine, NULL);
    17. 	
    18.     while (1){
    19. 		printf("main thread tid: %p\n", pthread_self());
    20. 		sleep(2);
    21. 	}
    22. 	return 0;
    23. }

  • 相关阅读:
    数据结构小记【Python/C++版】——树与二叉树篇
    关于python多线程的一些理解
    2023 ICPC 网络赛 第一场（补题：F）
    同城外卖跑腿小程序开发的关键步骤
    vue3+antdv 表格封装
    Kubernetes技术与架构-网络 2
    判断两个二叉树是否相等
    CSDN 重新开放付费资源的上传了，但要求如下
    MFC程序创建word，创建表格，写入数据
    微服务组件--注册中心Spring Cloud Eureka分析
  • 原文地址：https://blog.csdn.net/m0_52169086/article/details/125536137