#define MAXSIZE 1000
semaphore mutex = 1;//对环形缓冲区互斥访问
semaphore mutex_batch = 1;//某一进程取走10个数据后，别的进程才能取数据
semaphore empty = MAXSIZE;//还能放入多少个产品
semaphore full = 0;//已经放入了多少个产品
ElemType buffer[MAXSIZE];
int rear = 0;//队尾
int front = 0;//队头

CoBegin{

product_i(){
while(true){
p(empty);
p(mutex);
放入buffer[rear]中一个产品;
v(mutex);
v(full);
rear = (rear+1)% MAXSIZE;
}
}

consumer_i(){
while(true){
p(mutex_batch);
for(int i = 1; i <= 10; i++){
p(full);
p(mutex);
从buffer[rear]中取走一个产品;
v(mutex);
v(empty);
front = (front+1) % MAXSIZE;
}
v(mutex_batch);
}
}




}CoEnd