读者写者
- 格式:doc
- 大小:107.00 KB
- 文档页数:15
1 读者/写者实验报告 ――多线程的实现
一、实验要求 在Windows 2000/XP环境下,创建一个控制台进程,此进程包含 n 个线程。用这 n 个线程来表示 n 个读者或写者。每个线程按相应测试数据文件(格式见下)的要求进行读写操作。用信号量机制分别实现读者优先和写者优先的读者/写者问题(详见课本5.7)。 运行结果显示要求:要求在每个线程创建、发出读写操作申请、开始读写操作和结束读写操作时分别显示一行提示信息,以确定所有处理都遵守相应的读写操作限制。 测试数据文件格式如下: 测试数据文件包括 n 行测试数据,分别描述创建的n 个线程是读者还是写者,以及读写操作的开始时间和持续时间。每行测试数据包括4个字段,各个字段间用空格分隔。 第一个字段为一个正整数,表示线程序号 第二个字段表示相应线程角色,R表示读者,W表示写者 第三个字段为一个正数,表示读/写操作的开始时间:线程创建后,延迟相应时间(单位为秒)后发出对共享资源的读/写请求 第四个字段为一正数,表示读/写操作的持续时间:线程读写请求成功后,开始对共享资源的读/写操作,该操作持续相应时间后结束,并释放共享资源 例如: 1 R 3 5 2 W 4 5 3 R 5 2 4 R 6 5 5 W 5.1 3
二、实验理解分析与设计
1.进程和线程 在Windows32位操作系统中,所谓多任务是指系统可以同时运行多个进程,而每个进程也可以同时执行多个线程。 所谓进程就是应用程序的运行实例。每个进程都有自己私有的虚拟地址空间。每个进程都有一个主线程,但可以建立另外的线程。进程中的线程是并发执行的,每个线程占用CPU的时间由系统来划分。我们可以把线程看成是操作系统分配CPU时间的基本实体。 进程中的所有线程共享进程的虚拟地址空间,这意味着所有线程都可以访问进程的全局变量和资源。这一方面为编程带来了方便,但另一方面也容易造成冲突。 2
虽然在进程中进行费时的工作不会导致系统的挂起,但这会导致进程本身的挂起。所以,如果进程既要进行长期的工作,又要响应用户的输入,那么它可以启动一个线程来专门负责费时的工作,而主线程仍然可以与用户进行交互。
2.线程的同步 多线程的使用会产生一些新的问题,主要是如何保证线程的同步执行。多线程应用程序需要使用同步对象和等待函数来实现同步。同步问题是实现远程数据采集或远程自动控制编程中的关键技术问题。
3.同步的原因 由于同一进程的所有线程共享进程的虚拟地址空间,并且线程的中断是汇编语言级的,所以可能会发生两个线程同时访问同一个对象(包括全局变量、共享资源、API函数和MFC对象等)的情况,这有可能导致程序错误。例如,如果一个线程在未完成对某一大尺寸全局变量的读操作时,另一个线程又对该变量进行了写操作,那么第一个线程读入的变量值可能是一种修改过程中的不稳定值。 属于不同进程的线程在同时访问同一内存区域或共享资源时,也会存在同样的问题。 因此,在多线程应用程序中,常常需要采取一些措施来同步线程的执行。
4.同步的方法 由于线程间需要同步机制,才能协调运行。在Windows32编程中,主要提供了以下几种方法。
等待函数 这些函数只有在作为其参数的一个或多个同步对象产生信号时才会返回。在超过规定的等待时间后,不管有无信号,函数也都会返回。在等待函数未返回时,线程处于等待状态,此时线程只消耗很少的CPU时间。 使用等待函数即可以保证线程的同步,又可以提高程序的运行效率。最常用的等待函数是WaitForSingleObject,该函数的声明为: DWORD WaitForSingleObject(HANDLE hHandle, DWORD dwMilliseconds); 参数hHandle是同步对象的句柄。参数dwMilliseconds是以毫秒为单位的超时间隔,如果该参数为0,那么函数就测试同步对象的状态并立即返回,如果该参数为INFINITE,则超时间隔是无限的。
同步对象 同步对象用来协调多线程的执行,它可以被多个线程共享。线程的等待函数用同步对象的句柄作为参数,同步对象应该是所有要使用的线程都能访问到的。同步对象的状态要么是有信号的,要么是无信号的。同步对象主要有三种:事件、mutex和信号灯。 事件对象(Event)是最简单的同步对象,它包括有信号和无信号两种状态。在线程访 问某一资源之前,也许需要等待某一事件的发生,这时用事件对象最合适。例如,只有在通 3
信端口缓冲区收到数据后,监视线程才被激活。 Mutex对象的状态在它不被任何线程拥有时是有信号的,而当它被拥有时则是无信 号的。mutex对象很适合用来协调多个线程对共享资源的互斥访问(mutually exclusive)。 信号灯对象维护一个从0开始的计数,在计数值大于0时对象是有信号的,而在计 数值为0时则是无信号的。信号灯对象可用来限制对共享资源进行访问的线程数量。线程用CreateSemaphore函数来建立信号灯对象,在调用该函数时,可以指定对象的初始计数和最大计数。在建立信号灯时也可以为对象起个名字,别的进程中的线程可以用OpenSemaphore函数打开指定名字的信号灯句柄。
临界区和互锁变量的访问 临界区(Critical Seciton)与mutex的功能类似,但它只能由同一进程中的线程使用。临界区可以防止共享资源被同时访问。 进程负责为临界区分配内存空间,临界区实际上是一个CRITICAL_SECTION型的变量,它一次只能被一个线程拥有。在线程使用临界区之前,必须调用InitializeCriticalSection函数将其初始化。如果线程中有一段临界的代码不希望被别的线程中断,那么可以调用EnterCriticalSection函数来申请临界区的所有权,在运行完临界代码后再用LeaveCriticalSection函数来释放所有权。如果在调用EnterCriticalSection时临界区对象已被另一个线程拥有,那么该函数将无限期等待所有权。 利用互锁变量可以建立简单有效的同步机制。使用函数InterlockedIncrement和InterlockedDecrement可以增加或减少多个线程共享的一个32位变量的值,并且可以检查结果是否为0。线程不必担心会被其它线程中断而导致错误。如果变量位于共享内存中,那么不同进程中的线程也可以使用这种机制。
5.本实验的分析 由题目要求可知,这是一个实现多线程的使用,要求多个读者线程和多个写者线程共享读写临界区,而各个读者线程共享读进程资源,各个写线程共享写进程资源,所以这里包含了两个层次的共享,不凡把读写线程共享的临界区称为全局临界区,所有读线程共享的读进程的临界资源称为局部读临界区,所有写线程共享的写进程的临界资源称为局部写临界区。具体的关系如下图所示:
根据题目的要求还可以知道,在一个进程下的多个线程的并发情况:同是读进程的不同线程可以同时访问读写全局临界区,但是同时写进程的不同线程每次只能一个访问该读写全局临界区,还有就是读写线程不能同时访问读写全局临界区。
读进程 共享资源 读线程1 读线程2 读线程3 „„„„ 写进程 共享资源
写线程1 写线程2 写线程3 „„„„
读写线程共享的内存读写临界区 4
6.实验的设计 根据以上的进程和线程的理解以及对线程同步机制的分析,结合本次实验的特点,我设计出了以下的方案: 读线程间和写线程间对各自局部共享资源的访问修改采用Mutex对象,结合WaitForSingleObject保证互斥操作。 读线程与写线程争用全局临界资源采用临界区(Critical Seciton)。 统管读写线程的线程采用WaitForMultipleObjects保证等待所有的线程结束。
三、源程序
#include #include #include #include #include
#define MAX_THREAD_NUM 64 #define FILENAME "Thread.dat" int cur_time; int start_time; //全局变量 Global variable int readcount; int writecount;
//定义临界区 Define the critical section CRITICAL_SECTION RP_Write;//读者优先的"写临界区" CRITICAL_SECTION WP_Read;//写者优先的"读临界区" CRITICAL_SECTION WP_Write;//写者优先的"写临界区"
//定义读写进程的参数的结构 Define the datastructure of the parameter //of the read_process and write_process struct ThreadInfo{ int ID; char mode; double delayTime; double runTime; };
//定义进程数组和参数数组 Define the arrays for the process and parameter HANDLE h_Thread[MAX_THREAD_NUM]; ThreadInfo thread_info[MAX_THREAD_NUM];