生产者消费者问题的java实现

classBoundedBuffer{

finalLocklock=newReentrantLock();

finalConditionnotFull=lock.newCondition();

finalConditionnotEmpty=lock.newCondition();

finalObject[]items=newObject[100];

intputptr,takeptr,count;

publicvoidput(Objectx)throwsInterruptedException{

lock.lock();

while(count==items.length)

notFull.await();//一旦某个进程调用了await方法，他就进入了等待该条件集

合的状态，这里调用了await（），便进入了等待Notfull这个条件的状态，并且放弃了该锁

items[putptr]=x;

if(++putptr==items.length)putptr=0;

++count;

notEmpty.signal();链

}finally{

lock.unlock();

}

}

Put能够执行的条件不仅包括锁被解除，而且，他需要将阻塞状态维持到另一个进程

在同一个条件上调用singal()方法为止

publicObjecttake()throwsInterruptedException{

lock.lock();

try{

while(count==0)

notEmpty.await();

Objectx=items[takeptr];

if(++takeptr==items.length)takeptr=0;

--count;

notFull.signal();//当另一个进程发出一个信号使得NotFull条件为真时，

那么上面的notfull.await()时的阻塞状态解除

returnx;

}finally{

lock.unlock();

}

}

}