mutex =1;

for ( i = 0; i≦n2 – 1 ; i ++) {

empty[i]=m; full [i]=0; }

main ( ) {

cobegin

A1 ( ) ；

A2 ( ) ；

An1 ( ) ； B1 ( ) ； B2 ( ) ；

Bn2 ( ); coend }

send ( ) /*发送消息*/ {

int i;

for ( i = 0; i≦n2 – 1 ; i ++)

p ( empty[i] ) ; P ( mutex ) ;

将消息放入缓冲区；

v ( mutex )；

for ( i = 0; i≦n2 – 1 ; i ++)

v ( full [i] ) ;

}

receive ( ) /*进程B1接收消息*/ {

p ( full [i] ) ; P ( mutex ) ;

将消息从缓冲区中取出；

v ( mutex )；

… … v ( empty[i] ) ;

}

Ai ( ) /*因发送进程A1、A2，…An1的程序类似，这里只给出进程Ai的描述*/ {

while ( 1 ) {

send ( )； }

Bi ( ) /*因接受进程B1、B2，…Bn1的程序类似，这里只给出进程Bi的描述*/ {

while ( 1 ) {

receive ( i )； }

… … … …