浅谈java线程中生产者与消费者的问题

 更新时间:2016年07月15日 10:04:42   投稿:jingxian   我要评论

下面小编就为大家带来一篇浅谈java线程中生产者与消费者的问题。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧

一、概念

生产者与消费者问题是一个金典的多线程协作的问题.生产者负责生产产品,并将产品存放到仓库;消费者从仓库中获取产品并消费。当仓库满时,生产者必须停止生产,直到仓库有位置存放产品;当仓库空时,消费者必须停止消费,直到仓库中有产品。

解决生产者/消费者问题主要用到如下几个技术:1.用线程模拟生产者,在run方法中不断地往仓库中存放产品。2.用线程模拟消费者,在run方法中不断地从仓库中获取产品。3

 . 仓库类保存产品,当产品数量为0时,调用wait方法,使得当前消费者线程进入等待状态,当有新产品存入时,调用notify方法,唤醒等待的消费者线程。当仓库满时,调用wait方法,使得当前生产者线程进入等待状态,当有消费者获取产品时,调用notify方法,唤醒等待的生产者线程。

二、实例

package book.thread.product;

public class Consumer extends Thread{
  private Warehouse warehouse;//消费者获取产品的仓库
  private boolean running = false;//是否需要结束线程的标志位
  public Consumer(Warehouse warehouse,String name){
    super(name);
    this.warehouse = warehouse;
  }
  public void start(){
    this.running = true;
    super.start();
  }
  public void run(){
    Product product;
    try {
      while(running){
        //从仓库中获取产品
        product = warehouse.getProduct();
        sleep(500);
      }
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  } 
  //停止消费者线程
  public void stopConsumer(){
    synchronized(warehouse){
      this.running = false;
      warehouse.notifyAll();//通知等待仓库的线程
    }
  }
  //消费者线程是否在运行
  public boolean isRunning(){
    return running;
  }
}

 

package book.thread.product;

public class Producer extends Thread{
   private Warehouse warehouse;//生产者存储产品的仓库
  private static int produceName = 0;//产品的名字
  private boolean running = false;//是否需要结束线程的标志位

  public Producer(Warehouse warehouse,String name){
    super(name);
    this.warehouse = warehouse;
  }
  public void start(){
    this.running = true;
    super.start();
  }
  public void run(){
    Product product;
    //生产并存储产品
    try {
    while(running){
      product = new Product((++produceName)+"");
      this.warehouse.storageProduct(product);
      sleep(300);
      }
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }
  //停止生产者线程
  public void stopProducer(){
    synchronized(warehouse){
      this.running = false;
      //通知等待仓库的线程
      warehouse.notifyAll();
    }
  }
  //生产者线程是否在运行
  public boolean isRunning(){
    return running;
  }
}

 

package book.thread.product;

public class Product {
  private String name;//产品名
  public Product(String name){
    this.name = name;
  }
  public String toString(){
    return "Product-"+name;
  }
}

 

package book.thread.product;

//产品的仓库类,内部采用数组来表示循环队列,以存放产品
public class Warehouse {
  private static int CAPACITY = 11;//仓库的容量
  private Product[] products;//仓库里的产品
  //[front,rear]区间的产品未被消费
  private int front = 0;//当前仓库中第一个未被消费的产品的下标
  private int rear = 0;//仓库中最后一个未被消费的产品下标加1
  public Warehouse(){
    this.products = new Product[CAPACITY];
  }
  public Warehouse(int capacity){
    this();
    if(capacity > 0){
      CAPACITY = capacity +1;
      this.products = new Product[CAPACITY];
    }
  }

  //从仓库获取一个产品
  public Product getProduct() throws InterruptedException{
    synchronized(this){
      boolean consumerRunning = true;//标志消费者线程是否还在运行
      Thread currentThread = Thread.currentThread();//获取当前线程
      if(currentThread instanceof Consumer){
        consumerRunning = ((Consumer)currentThread).isRunning();
      }else{
        return null;//非消费者不能获取产品
      }
      //若消费者线程在运行中,但仓库中没有产品了,则消费者线程继续等待
      while((front==rear) && consumerRunning){
        wait();
        consumerRunning = ((Consumer)currentThread).isRunning();
      }
      //如果消费者线程已经停止运行,则退出该方法,取消获取产品
      if(!consumerRunning){
        return null;
      }
      //获取当前未被消费的第一个产品
      Product product = products[front];
      System.out.println("Consumer[" + currentThread.getName()+"] getProduct:"+product);
      //将当前未被消费产品的下标后移一位,如果到了数组末尾,则移动到首部
      front = (front+1+CAPACITY)%CAPACITY;
      System.out.println("仓库中还没有被消费的产品数量:"+(rear+CAPACITY-front)%CAPACITY);
      //通知其他等待线程
      notify();
      return product;
    }
  }
  //向仓库存储一个产品
  public void storageProduct(Product product) throws InterruptedException{
  synchronized(this){
    boolean producerRunning = true;//标志生产者线程是否在运行
    Thread currentThread = Thread.currentThread();
    if(currentThread instanceof Producer){
      producerRunning = ((Producer)currentThread).isRunning();
    }else{
      return;
    }
    //如果最后一个未被消费的产品与第一个未被消费的产品的下标紧挨着,则说明没有存储空间了。
    //如果没有存储空间了,而生产者线程还在运行,则生产者线程等待仓库释放产品
    while(((rear+1)%CAPACITY == front) && producerRunning){
      wait();
      producerRunning = ((Producer)currentThread).isRunning();
    }
    //如果生产线程已经停止运行了,则停止产品的存储
    if(!producerRunning){
      return;
    }
    //保存产品到仓库
    products[rear] = product;
    System.out.println("Producer[" + Thread.currentThread().getName()+"] storageProduct:" + product);
    //将rear下标循环后移一位
    rear = (rear + 1)%CAPACITY;
    System.out.println("仓库中还没有被消费的产品数量:"+(rear + CAPACITY -front)%CAPACITY);
    notify();
    }
  }
}

 

package book.thread.product;

public class TestProduct {
  public static void main(String[] args) {
    Warehouse warehouse = new Warehouse(10);//建立一个仓库,容量为10
    //建立生产者线程和消费者
    Producer producers1 = new Producer(warehouse,"producer-1");
    Producer producers2 = new Producer(warehouse,"producer-2");
    Producer producers3 = new Producer(warehouse,"producer-3");
    Consumer consumer1 = new Consumer(warehouse,"consumer-1");
    Consumer consumer2 = new Consumer(warehouse,"consumer-2");
    Consumer consumer3 = new Consumer(warehouse,"consumer-3");
    Consumer consumer4 = new Consumer(warehouse,"consumer-4");
    //启动生产者线程和消费者线程
    producers1.start();
    producers2.start();
    consumer1.start();
    producers3.start();
    consumer2.start();
    consumer3.start();
    consumer4.start();
    //让生产者/消费者程序运行1600ms
    try {
      Thread.sleep(1600);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    //停止消费者线程
    producers1.stopProducer();
    consumer1.stopConsumer();
    producers2.stopProducer();
    consumer2.stopConsumer();
    producers3.stopProducer();
    consumer3.stopConsumer();
    consumer4.stopConsumer();
  }
}

输出结果:

Producer[producer-1] storageProduct:Product-1
仓库中还没有被消费的产品数量:1
Consumer[consumer-2] getProduct:Product-1
仓库中还没有被消费的产品数量:0
Producer[producer-3] storageProduct:Product-3
仓库中还没有被消费的产品数量:1
Producer[producer-2] storageProduct:Product-2
仓库中还没有被消费的产品数量:2
Consumer[consumer-3] getProduct:Product-3
仓库中还没有被消费的产品数量:1
Consumer[consumer-1] getProduct:Product-2
仓库中还没有被消费的产品数量:0
Producer[producer-1] storageProduct:Product-4
仓库中还没有被消费的产品数量:1
Consumer[consumer-4] getProduct:Product-4
仓库中还没有被消费的产品数量:0
Producer[producer-3] storageProduct:Product-6
仓库中还没有被消费的产品数量:1
Producer[producer-2] storageProduct:Product-5
仓库中还没有被消费的产品数量:2
Consumer[consumer-1] getProduct:Product-6
仓库中还没有被消费的产品数量:1
Consumer[consumer-2] getProduct:Product-5
仓库中还没有被消费的产品数量:0
Producer[producer-1] storageProduct:Product-7
仓库中还没有被消费的产品数量:1
Consumer[consumer-3] getProduct:Product-7
仓库中还没有被消费的产品数量:0
Producer[producer-3] storageProduct:Product-8
仓库中还没有被消费的产品数量:1
Producer[producer-2] storageProduct:Product-9
仓库中还没有被消费的产品数量:2
Consumer[consumer-4] getProduct:Product-8
仓库中还没有被消费的产品数量:1
Producer[producer-1] storageProduct:Product-10
仓库中还没有被消费的产品数量:2
Producer[producer-3] storageProduct:Product-11
仓库中还没有被消费的产品数量:3
Producer[producer-2] storageProduct:Product-12
仓库中还没有被消费的产品数量:4
Consumer[consumer-1] getProduct:Product-9
仓库中还没有被消费的产品数量:3
Consumer[consumer-2] getProduct:Product-10
仓库中还没有被消费的产品数量:2
Consumer[consumer-3] getProduct:Product-11
仓库中还没有被消费的产品数量:1
Producer[producer-3] storageProduct:Product-13
仓库中还没有被消费的产品数量:2
Producer[producer-1] storageProduct:Product-14
仓库中还没有被消费的产品数量:3
Producer[producer-2] storageProduct:Product-15
仓库中还没有被消费的产品数量:4
Consumer[consumer-4] getProduct:Product-12
仓库中还没有被消费的产品数量:3
Consumer[consumer-1] getProduct:Product-13
仓库中还没有被消费的产品数量:2
Consumer[consumer-2] getProduct:Product-14
仓库中还没有被消费的产品数量:1
Producer[producer-1] storageProduct:Product-16
仓库中还没有被消费的产品数量:2
Producer[producer-3] storageProduct:Product-17
仓库中还没有被消费的产品数量:3
Producer[producer-2] storageProduct:Product-18
仓库中还没有被消费的产品数量:4

分析:在main方法中建立了一个产品仓库,并未该仓库关联了3个生产者线程和4个消费者线程,启动这些线程,使生产 者/消费者模型运作起来,当程序运行1600ms时,所有的生产者停止生产产品,消费者停止消费产品。

生产者线程Product在run方法中没300ms便生产一个产品,并存入仓库;消费者线程Consumer在run方法中没500ms便从仓库中取一个产品。

仓库类Warehouse负责存放产品和发放产品。storageProduct方法负责存储产品,当仓库满时,当前线程进入等待状态,即如果生产者线程A在调用storageProduct方法以存储产品时,发现仓库已满,无法存储时,便会进入等待状态。当存储产品成功时,调用notify方法,唤醒等待的消费者线程。

getProduct方法负责提前产品,当仓库空时,当前线程进入等待状态,即如果消费者线程B在调用getProduct方法以获取产品时,发现仓库空了,便会进入等待状态。当提取产品成功时,调用notify方法,唤醒等待的生产者线程。

以上这篇浅谈java线程中生产者与消费者的问题就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • 老生常谈java中cookie的使用

    老生常谈java中cookie的使用

    下面小编就为大家带来一篇老生常谈java中cookie的使用。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-12-12
  • Java中JDBC事务与JTA分布式事务总结与区别

    Java中JDBC事务与JTA分布式事务总结与区别

    Java事务的类型有三种:JDBC事务、JTA(Java Transaction API)事务、容器事务,本文详细介绍了JDBC事务与JTA分布式事务,有需要的可以了解一下。
    2016-11-11
  • java实现List中对象排序的方法

    java实现List中对象排序的方法

    这篇文章主要介绍了java实现List中对象排序的方法,涉及Java中的遍历与对象操作技巧,具有一定参考借鉴价值,需要的朋友可以参考下
    2015-11-11
  • Java编程访问权限的控制代码详解

    Java编程访问权限的控制代码详解

    这篇文章主要介绍了Java编程访问权限的控制代码详解,涉及包名,公共的和私有的等相关内容,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
    2018-01-01
  • java 图片加水印实例代码

    java 图片加水印实例代码

    java 图片加水印实例代码,需要的朋友可以参考一下
    2013-06-06
  • Java根据正整数的位数并逆序打印出各位数字

    Java根据正整数的位数并逆序打印出各位数字

    给一个不多于5位的正整数,要求:一、求它是几位数,二、逆序打印出各位数字,需要的朋友可以参考下
    2017-02-02
  • 关于Mybatis 中使用Mysql存储过程的方法

    关于Mybatis 中使用Mysql存储过程的方法

    这篇文章给大家介绍了Mybatis 中使用Mysql存储过程的方法,本文通过实例代码相结合的形式给大家介绍的非常详细,具有参考借鉴价值,需要的朋友参考下吧
    2018-03-03
  • 邻接表无向图的Java语言实现完整源码

    邻接表无向图的Java语言实现完整源码

    这篇文章主要介绍了邻接表无向图的Java语言实现完整源码,具有一定借鉴价值,需要的朋友可以参考下。
    2017-12-12
  • java基础学习笔记之类加载器

    java基础学习笔记之类加载器

    java中的类加载器:java虚拟机中可以安装多个类加载器,系统默认三个主要类加载器,每个类负责加载特定位置的类:BootStrap, ExtClassLoader,AppClassLoader类加载器也是一个java类,因此类加载器也需要被加载,所以必须有第一个类加载器不是java类
    2016-02-02
  • Spring Boot集成spring-boot-devtools开发时实现热部署的方式

    Spring Boot集成spring-boot-devtools开发时实现热部署的方式

    这篇文章主要介绍了Spring Boot集成spring-boot-devtools开发时实现热部署的方式,文中还给大家提到了spring boot 实现热部署的方式及集成注意事项,感兴趣的朋友跟随脚本之家小编一起学习吧
    2018-05-05

最新评论