java 中多线程生产者消费者问题详细介绍
java中多线程生产者消费者问题
前言：
一般面试喜欢问些线程的问题，较基础的问题无非就是死锁，生产者消费者问题，线程同步等等，在前面的文章有写过死锁，这里就说下多生产多消费的问题了
importjava.util.concurrent.locks.*;
classBoundedBuffer{
finalLocklock=newReentrantLock();//对象锁
finalConditionnotFull=lock.newCondition();//生产者监视器
finalConditionnotEmpty=lock.newCondition();//消费者监视器
//资源对象
finalObject[]items=newObject[10];
//putptr生产者角标，takeptr消费者角标，count计数器(容器的实际长度)
intputptr,takeptr,count;
publicvoidput(Objectx)throwsInterruptedException{
//生产者拿到锁
lock.lock();
try{
//当实际长度不满足容器的长度
while(count==items.length)
//生产者等待
notFull.await();
//把生产者产生对象加入容器
items[putptr]=x;
System.out.println(Thread.currentThread().getName()+"put-----------"+count);
Thread.sleep(1000);
//如果容器的实际长==容器的长，生产者角标置为0
if(++putptr==items.length)putptr=0;
++count;
//唤醒消费者
notEmpty.signal();
}finally{
//释放锁
lock.unlock();
}
}
publicObjecttake()throwsInterruptedException{
lock.lock();
try{
while(count==0)
//消费者等待
notEmpty.await();
Objectx=items[takeptr];
System.out.println(Thread.currentThread().getName()+"get-----------"+count);
Thread.sleep(1000);
if(++takeptr==items.length)takeptr=0;
--count;
//唤醒生产者
notFull.signal();
returnx;
}finally{
//释放锁
lock.unlock();
}
}
}
classConsuimplementsRunnable{
BoundedBufferbbuf;
publicConsu(BoundedBufferbbuf){
super();
this.bbuf=bbuf;
}
@Override
publicvoidrun(){
while(true){
try{
bbuf.take();
}catch(InterruptedExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
}
}
classProduimplementsRunnable{
BoundedBufferbbuf;
inti=0;
publicProdu(BoundedBufferbbuf){
super();
this.bbuf=bbuf;
}
@Override
publicvoidrun(){
while(true){
try{
bbuf.put(newString(""+i++));
}catch(InterruptedExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}
}
}
//主方法
classLock1{
publicstaticvoidmain(String[]args){
BoundedBufferbbuf=newBoundedBuffer();
Consuc=newConsu(bbuf);
Produp=newProdu(bbuf);
Threadt1=newThread(p);
Threadt2=newThread(c);
t1.start();
t2.start();
Threadt3=newThread(p);
Threadt4=newThread(c);
t3.start();
t4.start();
}
}
这个是jdk版本1.5以上的多线程的消费者生产者问题，其中优化的地方是把synchronized关键字进行了步骤拆分，对对象的监视器进行了拆离，synchronized同步，隐式的建立1个监听，而这种可以建立多种监听，而且唤醒也优化了，之前如果是synchronized方式，notifyAll(),在只需要唤醒消费者或者只唤醒生产者的时候，这个notifyAll()将会唤醒所有的冻结的线程，造成资源浪费，而这里只唤醒对立方的线程。代码的解释说明，全部在源码中，可以直接拷贝使用。
如有疑问请留言或者到本站社区交流讨论，希望通过本文能帮助到大家，谢谢大家对本站的支持！