Java多线程练习二：生产者消费者问题(线程通信)

84 阅读 0 评论 56 点赞

我是靠谱客的博主贪玩大叔，最近开发中收集的这篇文章主要介绍Java多线程练习二：生产者消费者问题(线程通信)，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

Java多线程练习二：生产者消费者问题(线程通信)

生产者（productor）将产品交给店员（clerk），消费者（customer）从店员处取走产品，生产者（productor）将产品交给店员（clerk），消费者（customer）从店员处取走产品，店员一次只能持有固定数量的产品（比如20），如果生产者试图生产更多的产品，店员会叫生产者停一下，如果店中有空位了再叫生产者生产；如果店中没有产品，店员会告知消费者等一下，如果店中有产品了再来消费。

分析：
1.类：生产者，消费者，产品，店员。
2.生产者与消费者都为多线程，可以有多个生产者，也可以有多个消费者。代码写了1个生产者线程与2个消费者线程，因为没有设置速度，所以执行出来基本是买的比卖的快，库存个数很少。
3.共享数据：产品、店员。

###代码^^：

class Product {
    private int number = 0;

    //产品生产方法
    public synchronized void shengchan() {
        if (number < 20) {
            number++;
            System.out.println(Thread.currentThread().getName() + "生产，产品库存为：" + number);
            notify();
        } else {
            try {
                this.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    //消费产品方法
    public synchronized void xiaofei() {
        if (number > 0) {
            number--;
            System.out.println(Thread.currentThread().getName() + "消费，产品库存为：" + number);
            notify();
        } else {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

//可以用来当做同步监视器
class Clerk {

}

class Productor implements Runnable {
    private Product product;
	//构造方法
    public Productor(Product product) {
        this.product = product;
    }

    @Override
    public void run() {
        System.out.println("开始生产");
        while (true) {
            product.shengchan();
        }
    }
}

class Customer implements Runnable {
    private Product product;
	//构造方法
    public Customer(Product product) {
        this.product = product;
    }

    @Override
    public void run() {
        System.out.println("开始消费");
        while (true) {
            product.xiaofei();
        }
    }
}


public class ProducterTest {
    public static void main(String[] args) {
        Product product = new Product();
        Productor productor = new Productor(product);
        Customer customer = new Customer(product);
        //生产者线程
        Thread productor1 = new Thread(productor);
        productor1.setName("生产者1");
        //消费者线程
        Thread customer1 = new Thread(customer);
        Thread customer2 = new Thread(customer);
        customer1.setName("消费者1");
        customer2.setName("消费者2");

        productor1.start();
        customer1.start();
        customer2.start();
    }
}