生产者和消费者相关问题

semaphore  offer=1,P1,P2,P3, sugar,water,orange;
int mutex = 1;
begin
process_offer(){
　　while(offer == 0){
　　　　P(mutex);
　　　　P(offer);
　　　　offer();
　　　　if(offer(orange))
　　　　　　P(orange);
　　　　　　V(P1);
　　　　else if(offer(sugar))
　　　　　　P(sugar);
　　　　　　V(P2);
　　　　else (offer(water))
　　　　　　P(water);
　　　　　　V(P3);
　　　　V(mutex);
}
process_P1(){
　　while(offer(orange)){
　　　　P(mutex);
　　　　P(P1);
　　　　V(orange);
　　　　V(mutex)
　　　　produce();　　//生产橘子汁
　　　　V(offer);
　　}
}

process_P2(){
　　while(offer(sugar)){
　　　　P(mutex);
　　　　P(P2);
　　　　V(sugar);
　　　　V(mutex)
　　　　produce();　　//生产橘子汁
　　　　V(offer);
　　}
}

process_P3(){
　　while(offer(water)){
　　　　P(mutex);
　　　　P(P3);
　　　　V(water);
　　　　V(mutex)
　　　　produce();　　//生产橘子汁
　　　　V(offer);
　　}
}

int B1[],B2[];
int in = 0;
int out = 0;
semaphore M,N,O;

process_Input(){
   while(in < M){
    P(M);
    append to B1[in];
    in++;
    输入进程;
    V(N);
   }
}

process_Process(){
   while(in > 0 && out < N){
    P(N);
    remove from B1[in]
    in--;
    append to B2[out];
    out++;
       处理进程;
    V(M);
    V(O);
   }
}

process_Output(){
   while(out > 0){
    P(O);
    remove from B2[out];
    out--;
    输出进程;
   }
}