进程间互斥、同步与通信.ppt

《进程间互斥、同步与通信.ppt》由会员分享，可在线阅读，更多相关《进程间互斥、同步与通信.ppt（49页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、第六章 进程间互斥、同步与通信授课教师：付勇智西南林学院 基础部数理教研室问题纲要间接制约和直接制约是什么？什么是临界区？什么是信号量？什么是同步、互斥？如何应用信号量实现同步和互斥？信号量在Windows编程中是如何实现的？进程并发运行所带来的问题由于系统资源的共享性，并发进程的执行结果失去了封闭性和可再现性。满足Bernstein条件的并发进程能够保持封闭性，但是Bernstein条件限制太过严格，不符合大多数实际环境的需要。因而，OS需要寻求一种机制，满足进程间共享资源的需要。进程间通信IPC在两个或多个进程间传递信息或共享数据的机制，称之为进程间通信（Inter-Process Com

2、munication）UNIX操作系统中的管道技术（Pipe）就是一种IPC在IPC的过程中，主要要解决两类问题：互斥和同步互斥的需要void SendPrint()1 if(in+1)%N=out)2 exit(0);3 else4 in=(in+1)%N;5 filein=printfile;6 return;ProcessA()SendPrint()ProcessB()SendPrint()临界区（Critical Section)临界资源：一次仅允许一个进程使用的资源称为临界资源。临界区：进程中对于临界资源访问的程序段称为临界区。间接制约：由于共享某一公有资源而引起的在临界区内不允许并

3、发进程交叉执行的现象，称为由共享公有资源造成的并发进程执行速度的间接制约，简称间接制约。互斥：一组并发进程中的一个或多个程序段，因共享某一公有资源而导致他们不能同时进入临界区称为互斥。互斥（Mutual Exclusion）互斥方案应满足的4个条件任何两个进程不能同时处于临界区不应对CPU的数目和速度做任何假设临界区外的进程不得阻塞其他进程不得使进程在临界区外无休止地等待互斥的实现方案关中断锁变量严格轮换法Peterson方案TSL硬件指令（Intel平台为BTS指令）信号量管程消息传递关中断处理机的调度都是由中断所引起的（主要是定时器中断）处理机的调度都是由中断所引起的（主要是定时器中断）如

4、果进入临界区前将所有外部中断屏蔽，则在运行临界如果进入临界区前将所有外部中断屏蔽，则在运行临界区时将不会响应所有外部中断事件，也就不可能发生进区时将不会响应所有外部中断事件，也就不可能发生进程切换，待进程执行完临界区后再开中断。程切换，待进程执行完临界区后再开中断。缺点：交由用户进程管理中断的开关是非常不安全的，缺点：交由用户进程管理中断的开关是非常不安全的，一旦用户程序关中断后忘记打开，则整个系统将无法响一旦用户程序关中断后忘记打开，则整个系统将无法响应外部事件而崩溃；另外，在多处理器系统中，关中断应外部事件而崩溃；另外，在多处理器系统中，关中断也仅屏蔽本处理器的中断响应，对其他处理器中运行

5、的也仅屏蔽本处理器的中断响应，对其他处理器中运行的进程无法屏蔽。进程无法屏蔽。因而通常中断屏蔽都由因而通常中断屏蔽都由OSOS进行管理，由进行管理，由OSOS使用它来保证使用它来保证一些核心操作的不可中断性。一些核心操作的不可中断性。锁变量int lock=0;int lock=0;/初始情况下没有进程进入临界区初始情况下没有进程进入临界区Processi()Processi()while(lock=1);while(lock=1);/当其他进程在临界区工作时，忙等待当其他进程在临界区工作时，忙等待lock=1;lock=1;/设置锁变量，防止其他进程进入设置锁变量，防止其他进程进入criti

6、cal_section();critical_section();/进行临界区相关操作进行临界区相关操作lock=0;lock=0;/退出临界区后解锁，使其他进程可以进入退出临界区后解锁，使其他进程可以进入non_critical_section();non_critical_section();严格轮转法Peterson方案TSL指令（测试与设置指令）Intel CPU中对应的中对应的TSL指令汇编指令码为指令汇编指令码为BTS信号量(semaphore)信号量使在信号量使在19651965年提出的一种方法，他建议引年提出的一种方法，他建议引入一个新的变量类型，称作信号量。信号量是一入一个新

7、的变量类型，称作信号量。信号量是一个整数，其值可以为个整数，其值可以为0 0或某个正整数，分别表示或某个正整数，分别表示不可进入临界区以及能够进入的进程数目。不可进入临界区以及能够进入的进程数目。信号量：是一个仅能由同步原语对其进行操作的信号量：是一个仅能由同步原语对其进行操作的整型变量。整型变量。原语（原子操作）：操作过程不可中断，必须以原语（原子操作）：操作过程不可中断，必须以一个整体进行执行地系统基本操作一个整体进行执行地系统基本操作对于信号量操作的原语只有两个：对于信号量操作的原语只有两个：UPUP和和DOWNDOWNDOWN原语（P操作）(1)若信号量S大于0，则将S减1，P操作返回

8、，该进程继续执行(2)若信号量S等于0，则将进程挂入S的等待队列，将进程设置为阻塞状态，并转调度程序P原语原语S0S=S-1返回返回调用进程进入等待队列调用进程进入等待队列转进程调度转进程调度是否UP原语（V操作）(1)若信号量S的等待队列中有等待进程，则取队首进程，将其置为就绪状态并返回。(2)否则信号量S加1，并放回V原语原语是否有等待进程是否有等待进程S=S+1返回返回取队首进程置为就绪态取队首进程置为就绪态否是生产者消费者问题问题描述：两个进程共享一个公共的固定大小的缓问题描述：两个进程共享一个公共的固定大小的缓冲区。其中的一个，生产者，将信息放入缓冲区；冲区。其中的一个，生产者，将信

9、息放入缓冲区；另一个，消费者，从缓冲区中取出信息。另一个，消费者，从缓冲区中取出信息。当缓冲区已满，而此时生产者还想向其中放入一个当缓冲区已满，而此时生产者还想向其中放入一个新的信息则让生产者睡眠，待消费者从缓冲区取走新的信息则让生产者睡眠，待消费者从缓冲区取走一个或多个信息时再唤醒它。一个或多个信息时再唤醒它。当消费者试图从缓冲区中取信息而发现缓冲区为空当消费者试图从缓冲区中取信息而发现缓冲区为空时，它就睡眠，直到生产者向其中放入一些消息再时，它就睡眠，直到生产者向其中放入一些消息再将其唤醒。将其唤醒。生产者过程消费者过程直接制约与同步一组在异步环境下的并发进程，各自的执行结果互为对方的执行

10、条件，从而限制各进程的执行速度的过程称为并发进程间的直接制约。异步环境下的一组并发进程，因直接制约而互相发送消息而进行相互合作、相互等待，使得各进程按一定的速度执行的过程称为进程间的同步。生产者消费者问题信号量定义#define N 100semaphore mutex=1;/互斥信号量semaphore empty=N;/开始时候可用的消息缓冲区数为Nsemaphore full=0;/开始时候可用的消息为0生产者进程void producer()void producer()int item;int item;while(true)while(true)produce-item(&item

11、);produce-item(&item);/产生消息产生消息down(empty);down(empty);/获得一个消息缓冲块获得一个消息缓冲块down(mutex);down(mutex);/对消息的缓冲要互斥对消息的缓冲要互斥enter-item(item);enter-item(item);/将消息送入缓冲区将消息送入缓冲区up(mutex);up(mutex);/互斥结束互斥结束up(full);up(full);/增加一个可用消息增加一个可用消息 消费者进程void consumer()void consumer()int item;int item;while(true)whi

12、le(true)down(full);down(full);/获得一可用消息获得一可用消息down(mutex);down(mutex);/互斥访问消息缓冲区互斥访问消息缓冲区get-item(&item);get-item(&item);/取得消息并从队列删除取得消息并从队列删除up(mutex);up(mutex);/结束互斥结束互斥up(empty);up(empty);/增加一个空缓冲区增加一个空缓冲区 哲学家进餐问题五个哲学家围坐在一张圆桌周围，每个哲学家面前都有一盘通心粉，由于通心粉很滑，所以要两把叉子才能夹住。相邻两盘子之间有一把叉子，餐具摆放如右图所示哲学家生活的过程哲学家的生

13、活包括两种活动：即吃饭和思考。当一个哲学家觉得饿时，他就试图分两次去取他左边和右边的叉子，每次得到一把，并且不分次序。如果成功的获得两把叉子，他就开始吃饭，吃完以后放下叉子继续思考。问题：为每一个哲学家写一段程序来描述其行为，要求不能死锁。不正确解法#define N 5#define N 5void philosopher(int i)void philosopher(int i)while(true)while(true)think();think();take-fork(i);take-fork(i);take-fork(i+1)%N);take-fork(i+1)%N);eat();e

14、at();put-fork(i);put-fork(i);put-fork(i+1)%N);put-fork(i+1)%N);低效率的互斥可行解法#define N 5#define N 5semaphor mutex=1;semaphor mutex=1;void philosopher(int i)void philosopher(int i)while(true)while(true)think();think();down(mutex);down(mutex);take-fork(i);take-fork(i);take-fork(i+1)%N);take-fork(i+1)%N);e

15、at();eat();put-fork(i);put-fork(i);put-fork(i+1)%N);put-fork(i+1)%N);up(mutex);up(mutex);经典解法#define N 5#define N 5#define LEFT(i-1)%N#define LEFT(i-1)%N#define RIGHT(i+1)%N#define RIGHT(i+1)%N#define THINKING 0#define THINKING 0#define HUNGRY 1#define HUNGRY 1#define EATING 2#define EATING 2int sta

16、teNint stateNsemaphore mutex=1semaphore mutex=1semaphore sN=0,0,.,0semaphore sN=0,0,.,0哲学家过程void philosopher(int i)void philosopher(int i)while(true)while(true)think();think();take-forks(i);take-forks(i);eat();eat();put-forks(i);put-forks(i);void test(i)void test(i)if(statei=HUNGRY&if(statei=HUNGRY&

17、stateLEFT!=EATING&stateLEFT!=EATING&stateRIGHT!=EATING)stateRIGHT!=EATING)statei=EATING;statei=EATING;up(si);up(si);哲学家的两个主要动作void take-forks(int i)void take-forks(int i)down(&mutex);down(&mutex);statei=HUNGRY;statei=HUNGRY;test(i);test(i);up(mutex);up(mutex);down(si);down(si);void put-forks(int i)v

18、oid put-forks(int i)down(mutex);down(mutex);statei=THINKING;statei=THINKING;test(LEFT);test(LEFT);test(RIGHT);test(RIGHT);up(mutex);up(mutex);读者写者问题设想一个飞机订票系统，其中有许多竞争的进程试图读写其中的数据。多个进程同时读是可以接受的，但一个进程正在更新数据库，则所有其他进程都不能访问数据库，即使读操作也不行。问题：如何对读者和写者编写线程？semaphore mutex=1;semaphore mutex=1;semaphore db=1;se

19、maphore db=1;int rc=0;int rc=0;void reader()void reader()while(true)while(true)down(mutex);down(mutex);rc+=1;rc+=1;if(rc=1)down(db);if(rc=1)down(db);up(mutex);up(mutex);read-data-base();read-data-base();down(mutex);down(mutex);rc=rc-1;rc=rc-1;if(rc=0)up(db);if(rc=0)up(db);up(mutex);up(mutex);use-dat

20、a-read();use-data-read();写者过程void writer()void writer()while(true)while(true)think-up-data();think-up-data();down(db);down(db);write-data-base();write-data-base();up(db);up(db);理发师睡觉问题理发店里有一位理发师、一把理发椅和理发店里有一位理发师、一把理发椅和n n把供等把供等候理发顾客坐的椅子。如果没有顾客，则理发师候理发顾客坐的椅子。如果没有顾客，则理发师便在理发椅上睡觉。便在理发椅上睡觉。当一个顾客到来时，他必须叫

21、醒理发师；如果一当一个顾客到来时，他必须叫醒理发师；如果一个顾客到来时理发师正在理发，则如果有空椅子个顾客到来时理发师正在理发，则如果有空椅子可以坐，他们就坐下来等待；如果没有空椅子，可以坐，他们就坐下来等待；如果没有空椅子，他们就离开。他们就离开。问题：为理发师和顾客各编写一段程序，描述他问题：为理发师和顾客各编写一段程序，描述他们的行为，要求不能带有竞争条件。们的行为，要求不能带有竞争条件。信号量定义#define CHAIRS 5/椅子数目semaphore customers=0;/顾客数目semaphore barbers=0;/等候顾客的理发师数目semaphore mutex=1

22、;/等待队列互斥信号量int waiting=0;/等待队列void barber()void barber()while(true)while(true)down(customers)down(customers);down(mutex);down(mutex);waiting-;waiting-;up(barbers);up(barbers);up(mutex);up(mutex);cut-hair();cut-hair();void customer()void customer()down(mutex);down(mutex);if(waitingCHAIRS)if(waitingCH

23、AIRS)waiting+;waiting+;up(customers);up(customers);up(mutex);up(mutex);down(barbers);down(barbers);get-haircut();get-haircut();else up(mutex);else up(mutex);司机售票员问题一辆公共汽车上有一名司机和一名售票员，司机的工作是不停的循环执行如下步骤：“开车正常行车到站停车”，售票员的工作是不停的执行如下工作：“开车门等候乘客上车关车门售票”售票员必须等车到站停车后才能开车门；司机也必须等售票员关车门以后才能开车问题：试写两段程序，分别描述司机和

24、售票员的工作过程。司机、售票员问题 到站停车到站停车到站停车到站停车 开开开开 车车车车 开开开开 车车车车 门门门门 关关关关 车车车车 门门门门 售售售售 票票票票 正常行车正常行车正常行车正常行车。售票员售票员司机司机semaphore driving=0;semaphore driving=0;semaphore door=1;semaphore door=1;void driver()void driver()while(true)while(true)down(driving);down(driving);开车开车();();正常行车正常行车();();到站停车到站停车();();

25、up(door);up(door);void ticket-seller()void ticket-seller()while(true)while(true)down(door);down(door);开门开门();();等待乘客上车等待乘客上车();();关门关门();();up(driving);up(driving);售票售票();();两学校交通问题在南开大学和天津大学之间有一条弯曲的小路，其中从S到T一段路每次只允许一辆自行车通过，但中间有一个小的“安全岛”M，可供两辆自行车在从两端进入小路的情况下错车使用，如下图所示，试设计一个算法使来往的自行车均可顺利通过。学校交通图示M天津大

26、学天津大学南开大学南开大学SKTLsemaphore S2T=1;semaphore S2T=1;semaphore T2S=1;semaphore T2S=1;semaphore SK=1;semaphore SK=1;semaphore TL=1;semaphore TL=1;semaphore M=2;semaphore M=2;void bikeS2T()void bikeS2T()down(S2T);down(S2T);down(SK);down(SK);go-S-K();go-S-K();down(M);down(M);get-in-M();get-in-M();up(SK);up

27、(SK);down(TL);down(TL);up(M);up(M);go-L-T();go-L-T();up(TL);up(TL);up(S2T);up(S2T);void bikeT2S()void bikeT2S()down(T2S);down(T2S);down(TL);down(TL);go-T-L();go-T-L();down(M);down(M);get-in-M();get-in-M();up(TL);up(TL);down(SK);down(SK);up(M);up(M);go-K-S();go-K-S();up(SK);up(SK);up(T2S);up(T2S);Win

28、dows中的IPC实现信号量的创建HANDLE CreateSemaphore(LPSECURITY_ATTRIBUTES lpSemaphoreAttributes,/SD LONG lInitialCount,/initial count LONG lMaximumCount,/maximum count LPCTSTR lpName/object name);DOWN操作DWORD WaitForSingleObject(HANDLE hHandle,/handle to object DWORD dwMilliseconds/time-out interval);UP操作BOOL Re

29、leaseSemaphore(HANDLE hSemaphore,/handle to semaphore LONG lReleaseCount,/count increment amount LPLONG lpPreviousCount/previous count);示例.打开窗口数目的限制功能：通过一个循环，打开五个窗口，但同一时功能：通过一个循环，打开五个窗口，但同一时刻最多只能有三个窗口打开。刻最多只能有三个窗口打开。试用试用DOWNDOWN、UPUP操作先编写程序完成以上要求操作先编写程序完成以上要求semaphore count=3;semaphore count=3;OpenA

30、ction()OpenAction()DOWN(count);DOWN(count);DrawWindow();DrawWindow();while(WindowState()!=Close);while(WindowState()!=Close);UP(count);UP(count);Windows平台实现#include stdafx.h#include stdafx.hHANDLE hSemaphore;HANDLE hSemaphore;LONG cMax=3;LONG cMax=3;DWORD WINAPI thread_func(LPVOID lpParam)DWORD WINA

31、PI thread_func(LPVOID lpParam)LONG cPreviousCount;LONG cPreviousCount;char outinfo20;char outinfo20;WaitForSingleObject(hSemaphore,INFINITE);WaitForSingleObject(hSemaphore,INFINITE);MessageBox(NULL,Thread Message,MB_OK);MessageBox(NULL,Thread Message,MB_OK);ReleaseSemaphore(hSemaphore,1,&cPreviousCo

32、unt);ReleaseSemaphore(hSemaphore,1,&cPreviousCount);sprintf(outinfo,Previous Count=%d,cPreviousCount);sprintf(outinfo,Previous Count=%d,cPreviousCount);MessageBox(NULL,outinfo,MB_OK);MessageBox(NULL,outinfo,MB_OK);return 0;return 0;int APIENTRY WinMain(HINSTANCE hInstance,int APIENTRY WinMain(HINSTA

33、NCE hInstance,HINSTANCE hPrevInstance,HINSTANCE hPrevInstance,LPSTR lpCmdLine,LPSTR lpCmdLine,int nCmdShow)int nCmdShow)int i;int i;hSemaphore=CreateSemaphore(hSemaphore=CreateSemaphore(NULL,/no security attributesNULL,/no security attributescMax,/initial countcMax,/initial countcMax,/maximum countcMax,/maximum countNULL);/unnamed semaphoreNULL);/unnamed semaphorefor(i=0;i5;i+)for(i=0;i5;i+)CreateThread(NULL,0,thread_func,NULL,0,NULL);CreateThread(NULL,0,thread_func,NULL,0,NULL);Sleep(60000);Sleep(60000);return 0;return 0;