线程同步机制实验报告
- 格式:doc
- 大小:422.50 KB
- 文档页数:15
线程同步机制实验报告通过观察共享数据资源但不受控制的两个线程的并发运行输出结果,体会同步机制的必要性和重要性。
然后利用现有操作系统提供的同步机制编程实现关于该两个线程的有序控制,同时要求根据同步机制的Peterson软件解决方案尝试自己编程实现同步机制和用于同一问题的解决,并基于程序运行时间长短比较两种同步机制。
二、实验内容:1、基于给定银行账户间转账操作模拟代码作为线程执行代码,在主线程中创建两个并发线程,编程实现并观察程序运行结果和予以解释说明。
(无同步机制)2、利用Win32 API中互斥信号量操作函数解决上述线程并发问题,并分析、尝试和讨论线程执行体中有关信号量操作函数调用的正确位置。
3、根据同步机制的Peterson软件解决方案尝试自己编程实现线程同步机制和用于上述线程并发问题的解决,并基于程序运行时间长短将其与基于Win32 API互斥信号量的线程同步机制的效率展开比较。
其间,可规定线程主体代码循环执行1000000次。
三、实验环境:操作系统:Windows 7软件:VC++6.0●本实验包含三个基于并发线程的程序,第一个没有同步机制,第二个利用Win32 API中互斥信号量操作函数解决线程并发问题,第三个根据同步机制的Peterson软件解决方案实现线程同步机制并解决线程并发问题。
三个程序拥有相同的线程主体:线程主体设计:do{nTemp1 = nAccount1;nTemp2 = nAccount2;nRandom = rand();nAccount1 = nTemp1 + nRandom;nAccount2 = nTemp2 - nRandom;nLoop++;} while ((nAccount1 + nAccount2)==0);该线程主体是对银行账户间转账操作模拟的模拟,可知,若并发的线程不发生交叉,则依次转账操作后nAccount1 + nAccount2的值永远为0,程序不会跳出循环,如果线程发生交叉,则经过若干次转账操作后,就有可能出现nAccount1 + nAccount2不为0的情况,此时程序跳出循环。
本实验的三个程序就是基于此线程主体逐步实现的。
●同步机制的Peterson软件解决方案五、数据结构设计: 程序一:没有同步机制说明:ThreadFunc(HANDLE Thread)为线程函数;nAccount1、aAccount2模拟账户;nLoop记录循环次数;nRandom是产生的随机数模拟转账金额;nTemp1、nTemp2用于暂存nAccount1、aAccount2;HANDLE Thread[2]创建两个线程句柄。
程序二:利用Win32 API中互斥信号量说明:mutex为互斥信号量;time_start、time_end为线程开始运行和结束的时间;time=time_end- time_start。
●程序三:同步机制的Peterson软件解决方案说明:flag为长度为2的bool型数组,turn为整型,flag与turn共同实现同步机制的Peterson软件解决方案;nLoop1记录线程0的循环次数;nLoop记录线程1的循环次数。
六、算法流程图:●程序一:没有同步机制程序二:利用Win32 API中互斥信号量程序三:同步机制的Peterson软件解决方案开始创建两个线程线程1线程2nLoop1+nLoop2<1000000Y 输出循环次数结束等待资源flag[0]=true;turn=1;while(flag[1] && turn==1){}转账nLoop1++;释放资源转账nLoop2++;释放资源NN等待资源flag[0]=true;turn=1;while(flag[1] && turn==1){}七、实验过程结果截图:程序一:没有同步机制●程序二:利用Win32 API中互斥信号量●程序三:同步机制的Peterson软件解决方案八、实验结果分析:第一个程序两个线程并发并没有同步机制,所以产生了nAccount1 +nAccount2不为0的情况,程序跳出循环,一个线程结束,但剩余的一个线程自己是无法跳出循环的,所以程序一直在运行;第二个程序利用互斥信号并通过成功资源资源来解决并发带来的混乱;第三个程序通过同步机制的Peterson软件解决方案解决并发带来的混乱;通过结果可知,同步机制的Peterson软件解决方案的效率要高于利用Win32 API中互斥信号量的方法。
九、实验总结:●实验心得:通过本次实验,我锻炼里自己的编程能力,并对理论知识有了进一步的理解。
对线程并发问题有了进一步的体会,并掌握了同步线程的方法,特别是同步机制的Peterson软件解决方案。
同时我也体会到,学好这门课程,不光要掌握好理论,更重要的是要多实践,对实验现象多加分析研究,才会融会贯通所学的内容。
●实验评价:本实验按照实验指导书完成了要求的全部内容,成功得出了结果。
但实验程序也存在一些潜在的漏洞,比如第三个程序在多次执行中会出现总的循环次数不为1000000的情况,有待进一步完善。
十、实验程序清单:●程序一:没有同步机制#include <stdio.h>#include<windows.h>#include<stdlib.h>#include<iostream>using namespace std;int nAccount1=0, nAccount2=0;int nLoop=0;int nTemp1,nTemp2,nRandom;DWORD WINAPI ThreadFunc(HANDLE Thread){do{nTemp1 = nAccount1;nTemp2 = nAccount2;nRandom = rand();nAccount1 = nTemp1 + nRandom;nAccount2 = nTemp2 - nRandom;nLoop++;} while ((nAccount1 + nAccount2)==0);printf("循环次数为%d\n", nLoop);return 0;}int main(){HANDLE Thread[2];Thread[0]=CreateThread(NULL,0,ThreadFunc,NULL,0,NULL);Thread[1]=CreateThread(NULL,0,ThreadFunc,NULL,0,NULL);WaitForMultipleObjects(2,Thread,TRUE,INFINITE);CloseHandle(Thread);return 0;}程序二:利用Win32 API中互斥信号量#include <windows.h>#include <stdlib.h>#include <stdio.h>#include<iostream>using namespace std;#define COUNT 1000000int nAccount1 = 0, nAccount2 = 0;int nLoop = 0;int nTemp1, nTemp2, nRandom;HANDLE mutex;DWORD WINAPI ThreadFunc(LPVOID lpParamter){WaitForSingleObject(mutex,INFINITE);do{nTemp1 = nAccount1;nTemp2 = nAccount2;nRandom = rand();nAccount1 = nTemp1 + nRandom;nAccount2 = nTemp2 - nRandom;nLoop++;ReleaseMutex(mutex);WaitForSingleObject(mutex,INFINITE);}while (nAccount1+nAccount2 == 0 && nLoop<COUNT);printf("循环次数为%d\n", nLoop);ReleaseMutex(mutex);return 0;}int main(){long time;HANDLE Thread[2];DWORD time_start, time_end;time_start = GetTickCount();mutex = CreateMutex(NULL,FALSE,"screen");Thread[0] = CreateThread(NULL,0,ThreadFunc,NULL,0,NULL);Thread[1] = CreateThread(NULL,0,ThreadFunc,NULL,0,NULL);WaitForMultipleObjects(2,Thread,TRUE,INFINITE);CloseHandle(Thread);CloseHandle(mutex);time_end = GetTickCount();time=time_end-time_start;cout<<"总共用时:"<<time<<"ms"<<endl;return 0;}程序三:同步机制的Peterson软件解决方案#include <windows.h>#include <stdlib.h>#include<iostream>using namespace std;#define COUNT 1000000int nAccount1=0,nAccount2=0;int nLoop1 = 0;int nLoop2 = 0;int nTemp1=0,nTemp2=0,nRandom;bool flag[2];int turn;HANDLE mutex;DWORD WINAPI ThreadFunc0(HANDLE Thread){flag[0]=true; //这三行是模拟互斥信号量申请turn=1;while(flag[1] && turn==1){}do{nTemp1 = nAccount1;nTemp2 = nAccount2;nRandom = rand();nAccount1 = nTemp1 + nRandom;nAccount2 = nTemp2 - nRandom;nLoop1++;flag[0]=false; //释放资源flag[0]=true; //这三行是模拟互斥信号量申请turn=1;while(flag[1] && turn==1){}}while((nAccount1+nAccount2)==0 && (nLoop1+nLoop2)<COUNT );cout<<"1循环次数为:"<<nLoop1<<endl;flag[0]=false;return 0;}DWORD WINAPI ThreadFunc1(HANDLE Thread){flag[1]=true; //这三行是模拟互斥信号量申请turn=0;while(flag[0] && turn==0){}do{nTemp1=nAccount1;nTemp2=nAccount2;nRandom = rand();nAccount1 = nTemp1 + nRandom;nAccount2 = nTemp2 - nRandom;nLoop2++;flag[1]=false; //释放资源flag[1]=true; //这三行是模拟互斥信号量申请turn=0;while(flag[0] && turn==0){}}while((nAccount1+nAccount2)==0 && (nLoop1+nLoop2)<COUNT);cout<<"2循环次数为:"<<nLoop2<<endl;flag[1]=false;return 0;}int main(){long time;HANDLE Thread[2];DWORD time_start, time_end;time_start = GetTickCount();Thread[0] = CreateThread(NULL,0,ThreadFunc0,NULL,0,NULL);Thread[1] = CreateThread(NULL,0,ThreadFunc1,NULL,0,NULL);WaitForMultipleObjects(2,Thread,TRUE,INFINITE);CloseHandle(Thread);time_end = GetTickCount();time=time_end-time_start;cout<<"总共用时:"<<time<<"ms"<<endl;cout<<"总次数:"<<nLoop1+nLoop2<<endl;return 0;}。