程序的并发性和进程交互原语.pptVIP

从一个信道input接受字符流的过滤器进程char_to_Line。每当它接受满一行或见到CR符号就向输出信道output送出该行。CR为行结束符。异步通信的过滤器chaninput(char)，output([1..MAXLINE]:char);char_to_Line::varline[1..MAXLINE]:char，i:int:=1;loopreceiveinput(line[i]);whileline[i]=CRandiMAXLINEdoi:=i+1;receiveinput(line[i]);endsendoutput(line)；i:=1;endloop;…过滤器文件服务器操作系统中常用的文件服务器。它保持客户与服务器交谈的连续性。为了访问外存上的文件，客户首先要打开文件，文件存在表示成功，客户才能发出一系列读/写要求。最后由客户关闭文件。打开之后作读、写、关闭等操作，但打开的和操作的是同一文件(即连续交谈)。为了简化，文件都是一种类型，差别只在空不空，所以文件服务器也是N个进程，一个管一个。每一个对应一个访问信道。但打开文件的信道是全局的。为了简化，客户号、服务器号均以整数表示。客户/服务器异步通信实现typekind=enum(READ，WRITE，CLOSE);chanopen(fname:string*，clientid:int);chanaccess[1..N](kind，TYPE)；//可增细节信息chanopen_reply[1..N](int);chanaccess_reply[1..N](RTYPE，FLAG);File_Server[i:1..N]::varfname:string*，clientid:int;vark:kind，args:TYPE;varmore:bool:=false;var局部缓冲区，快速缓存，磁盘地址等;loopreceiveopen(fname，clientid);//打开文件fname，不成则等，若成:sendopen_reply[clientid](i);more:=true;whilemoredoreceiveaccess[i](k，args);ifk=READthen执行读操作;?ifk=WRITEthen执行写操作;?ifk=CLOSEthen关闭文件;more:=false;endif;sendaccess_reply[clientid](results);end;endloop基于消息传递的通讯机制client[j:1..M]::sendopen(“foo”，j)；//第j个客户要打开foo文件receiveopen_reply[j](serverid)//取server的号//准备访问数据k.argssendaccess[serverid](k，args)receiveaccess_reply[j](results)//取结果信息同步消息传递通信着的顺序进程CSP通信语句A::…B!e…//B!e是输出语句，目标是BB::…A?x…//A?x是输入语句，源自A进程目标进程!信道名(输出表达式表)源进程?信道名(输入参数表)基于消息传递的通讯机制我们把求最大公约数做成一服务器进程GCD。客户进程client每向它发送一对整数，它求出结果发回客户。GCD::varx，y:int;loopclient?ar