亲宝软件园·资讯

展开

java 多线程 java 中多线程生产者消费者问题仔细讲解

CC小观 人气:0
想了解java 中多线程生产者消费者问题仔细讲解的相关内容吗,CC小观在本文为您仔细讲解java 多线程的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:java,多线程,java,多线程生产者与消费者的问题,java,多线程生产消费者的问题解决办法,下面大家一起来学习吧。

java 中多线程生产者消费者问题

前言:

一般面试喜欢问些线程的问题,较基础的问题无非就是死锁,生产者消费者问题,线程同步等等,在前面的文章有写过死锁,这里就说下多生产多消费的问题了

import java.util.concurrent.locks.*;

class BoundedBuffer {
  final Lock lock = new ReentrantLock();//对象锁
  final Condition notFull = lock.newCondition(); //生产者监视器
  final Condition notEmpty = lock.newCondition(); //消费者监视器

  //资源对象
  final Object[] items = new Object[10];
  //putptr生产者角标,takeptr消费者角标,count计数器(容器的实际长度)
  int putptr, takeptr, count;

  public void put(Object x) throws InterruptedException {
    //生产者拿到锁
   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();
   }
  }

  public Object take() throws InterruptedException {
   lock.lock();
   try {
    while (count == 0) 
      //消费者等待
     notEmpty.await();
    Object x = items[takeptr]; 
    System.out.println(Thread.currentThread().getName()+"   get-----------"+count);
    Thread.sleep(1000);
    if (++takeptr == items.length) takeptr = 0;
    --count;
    //唤醒生产者
    notFull.signal();
    return x;
   } finally {
     //释放锁
    lock.unlock();
   }
  } 
 }

class Consu implements Runnable{
  BoundedBuffer bbuf;

  public Consu(BoundedBuffer bbuf) {
    super();
    this.bbuf = bbuf;
  }

  @Override
  public void run() {
    while(true){
    try {
      bbuf.take() ;
    } catch (InterruptedException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
    }
  }

}
class Produ implements Runnable{
  BoundedBuffer bbuf;
  int i=0;
  public Produ(BoundedBuffer bbuf) {
    super();
    this.bbuf = bbuf;
  }

  @Override
  public void run() {
    while(true){
      try {
        bbuf.put(new String(""+i++)) ;
      } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
      }
    }
  }

}



//主方法
class Lock1{
  public static void main(String[] args) {
    BoundedBuffer bbuf=new BoundedBuffer();
    Consu c=new Consu(bbuf);
    Produ p=new Produ(bbuf);
    Thread t1=new Thread(p);
    Thread t2=new Thread(c);
    t1.start();
    t2.start();
    Thread t3=new Thread(p);
    Thread t4=new Thread(c);
    t3.start();
    t4.start();
  }
}



这个是jdk版本1.5以上的多线程的消费者生产者问题,其中优化的地方是把synchronized关键字进行了步骤拆分,对对象的监视器进行了拆离,synchronized同步,隐式的建立1个监听,而这种可以建立多种监听,而且唤醒也优化了,之前如果是synchronized方式,notifyAll(),在只需要唤醒消费者或者只唤醒生产者的时候,这个notifyAll()将会唤醒所有的冻结的线程,造成资源浪费,而这里只唤醒对立方的线程。代码的解释说明,全部在源码中,可以直接拷贝使用。

如有疑问请留言或者到本站社区交流讨论,希望通过本文能帮助到大家,谢谢大家对本站的支持!

加载全部内容

相关教程
猜你喜欢
用户评论