操作系统实验线程管理与控制

1、第4章 线程管理与控制4.1 线程概念简介每个进程都拥有自己的数据段、代码段和堆栈段，这就造成了进程在进行切换等操作时都需要有比较复杂的上下文切换等动作。为了进一步减少处理机的空转时间，支持多处理器以及减少上下文切换开销，进程在演化中出现了另一个概念线程。它是进程内独立的一条运行路线，处理器调度的最小单元，也可以称为轻量级进程。线程可以对进程的内存空间和资源进行访问，并与同一进程中的其他线程共享。因此，线程的上下文切换的开销比创建进程小很多。同进程一样，线程也将相关的执行状态和存储变量放在线程控制块(TCB)内。一个进程可以有多个线程，也就是有多个线程控制块及堆栈寄存器，但却共享一个用户地址空

2、间。要注意的是，由于线程共享了进程的资源和地址空间，因此，任何线程对系统资源的操作都会给其他线程带来影响。由此可知，多线程中的同步是非常重要的问题。在多线程系统中，进程与进程的关系如图所示。进程与线程关系 4.2 Linux多线程编程API与实验任务4.3.1 Linux多线程编程API 创建线程pthread_create()函数实际上就是确定调用该线程函数的入口点，在线程创建以后，就开始运行相关的线程函数，在该函数运行完之后，该线程也就退出了，这也是线程退出一种方法。另一种退出线程的方法是使用函数pthread_exit()，这是线程的主动行为。这里要注意的是，在使用线程函数时，不能随意使

3、用exit()退出函数进行出错处理，由于exit()的作用是使调用进程终止，往往一个进程包含多个线程，因此，在使用exit()之后，该进程中的所有线程都终止了。因此，在线程中就可以使用pthread_exit()来代替进程中的exit()。由于一个进程中的多个线程是共享数据段的，因此通常在线程退出之后，退出线程所占用的资源并不会随着线程的终止而得到释放。正如进程之间可以用wait()系统调用来同步终止并释放资源一样，线程之间也有类似机制，那就是pthread_join()函数。pthread_join()可以用于将当前线程挂起来等待线程的结束。这个函数是一个线程阻塞的函数，调用它的函数将一直等

4、待到被等待的线程结束为止，当函数返回时，被等待线程的资源就被收回。（1）创建线程函数pthread_create()功能：创建线程和启动线程，与进程管理函数fork()的功能相似。pthread_create()函数语法要点所需头文件#include <pthread.h>函数原型int pthread_create (pthread_t *thread, pthread_attr_t *attr,void *(*start_routine)(void *), void *arg)函数传入值thread：线程标识符attr：线程属性设置（其具体设置参见9.2.3小节），通常取为NU

5、LLstart_routine：线程函数的起始地址，是一个以指向void的指针作为参数和返回值的函数指针arg：传递给start_routine的参数函数返回值成功：0出错：返回错误码(2) 线程退出函数pthread_exit()pthread_exit()函数语法要点所需头文件#include <pthread.h>函数原型void pthread_exit(void *retval)函数传入值retval：线程结束时的返回值，可由其他函数如pthread_join()来获取(3) 等待线程结束函数pthread_join()等待线程结束，读取线程的返回结果。pthread_j

6、oin()函数语法要点所需头文件#include <pthread.h>函数原型int pthread_join (pthread_t th, void *thread_return)函数传入值th：等待线程的标识符thread_return：用户定义的指针，用来存储被等待线程结束时的返回值（不为NULL时）函数返回值成功：0出错：返回错误码(4) 线程取消函数pthread_cancel()pthread_cancel()函数语法要点所需头文件#include <pthread.h>函数原型int pthread_cancel(pthread_t th)函数传入值th

7、：要取消的线程的标识符函数返回值成功：0出错：返回错误码4.3.3 Linux多线程同步API1. 线程同步信号量及系统调用POSIX的线程同步信号量定义了3个函数：(1) 信号量初始化函数说明：#include <semaphore.h>int sem_init(sem_t *sem,int pshared,unsigned value);参数说明：sem: 指向信号量变量的指针，*sem是定义好的信号量。pshared: 为0表示进程局部信号量，通常为0value: 信号量初始值，为1时是二值信号量返回值：0:执行成功，非0执行失败(2) 信号量加1原子操作int sem_po

8、st(sem_t *sem);说明：类似于进程的V操作。(3) 信号量减1原子操作int sem_wait(sem_t *sem)说明：在信线程号量值为0时执行该操作使线程进入等待状态，直到另一个线程执行加1原子操作为止。类似于进程的P操作。2. 线程互斥量及系统调用互斥量可在多线程程序中作为临界区互斥访问手段。操作互斥量的基本函数有：(1) 初始化函数函数说明：#include <semaphore.h>int phread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *mutexattr);参数说明：

9、mutex: 定义好的互斥量指针mutexattr：互斥量属性，通常可以为NULL(2) 加锁操作int pthread_mutex_lock(pthread_mutex_t *mutex);(3) 开锁操作int pthread_mutex_unlock(pthread_mutex_t *mutex);(4) 互斥量撤销操作int pthread_mutex_destroy(pthread_mutex_t *mutex);4.3.4 Linux多线程同步实验任务1. 用互斥量实现对4.3.2中多线程并发程序中共享变量的互斥访问。lin-thread-4.c:#include <stdi

10、o.h>#include <pthread.h>#include <unistd.h>static int a10000;static sum1,sum2,sum, p;pthread_mutex_t mutex; /互斥量，用于共享变量访问void *thread1(void *arg) int i;sum2=0;for(; ;) pthread_mutex_lock (&mutex);if (p<10000) sum2=sum2+ap;usleep(1);p+;pthread_mutex_unlock(&mutex);else pthre

11、ad_mutex_unlock(&mutex); break; pthread_exit(void*) sum2);int main(int argc,char* argv) pthread_t tidp; int error,i;int res;int thread_result;pthread_mutex_init (&mutex,NULL); /线程互斥量初始化为p=0; for (i=0; i<10000; i+) ai=i; error = pthread_create(&tidp,NULL, thread1,NULL); if(error != 0)

12、printf("thread is not created.n"); return -1; sum1=0;for(; ;) pthread_mutex_lock (&mutex);if (p<10000) sum1=sum1+ap;usleep(1);p+;pthread_mutex_unlock(&mutex);else pthread_mutex_unlock(&mutex); break; pthread_join(tidp,&thread_result); sum=sum1+sum2; printf("the sum

13、of array10000 is %dn",sum);printf("the part sum of thread1 get is %dn", thread_result); return 0;$ gcc lin-thread-4.c -lpthread -o lin-thread-4$ ./lin-thread-42. 分析、调试和执行一个多线程示例程序lin-thread-5.c该程序创建两个线程，一个线程负责读入键盘输入的文本，另一个线程负责统计和显示输入的字符个数，文本输入以“end”表示输入结束。程序在主线程中对结束的两个线程进行归并。lin-threa

14、d-5.c#include <stdio.h>#include <unistd.h>#include <stdlib.h>#include <string.h>#include <pthread.h>#include <semaphore.h>void *input_text(void *arg);void *count_text(void *arg);void *stat_text(void *arg);sem_t bin_sem;       

15、60;/信号量，用于线程同步#define WORK_SIZE 1024char work_areaWORK_SIZE;int main()         int res;       /线程函数执行的返回值        pthread_t input_thread,stat_thread;    /线程标识符变量 

16、;       void *thread_result; /线程执行的返回值        res = sem_init(&bin_sem,0,0);    /线程同步信号量初始化为0        if (res!=0)         &

17、#160;   perror("Semaphore init failed");            exit(EXIT_FAILURE);                res = pthread_create(&input_thread,NULL, inp

18、ut_text,NULL);         if (res!=0)             perror("Input Thread init failed");            exit(EXIT_FAILURE);   

19、;             res = pthread_create(&stat_thread,NULL, stat_text,NULL);        if (res!=0)             perror("Stat Thread init

20、 failed");            exit(EXIT_FAILURE);                printf("Waiting for thread to finishn");        

21、res = pthread_join(input_thread,&thread_result);        res = pthread_join(stat_thread,&thread_result);        printf("Threads joinedn");        sem_destroy(&bin_sem);        exit(EXIT_SUCCESS); void *input_text(void *arg)     printf("Input some text. Enter end to finishn");    while(strncmp("end",work_area,3)!=0)