生产者与消费者(升级版)，第4楼升级到可同时存放100个商品 - 黑马程序员技术交流社区

/*
需求分析：有一群生产者和一群消费者,
生产的商品都由一个对象来保存，生产者生产时，消费者不得进行购买动作，生产完成后才可以进行购买
同样消费者购买商品时生产者不得生产。
*/
class ProducerConsumer
{
public static void main(String[] args)
{
Resource r=new Resource();
Producer p=new Producer(r);
Consumer c=new Consumer(r);
new Thread(p,"生产者1").start();
new Thread(p,"生产者2").start();
new Thread(p,"生产者3").start();
new Thread(c,"消费者1").start();
new Thread(c,"消费者2").start();
new Thread(c,"消费者3").start();
new Thread(c,"消费者4").start();
new Thread(c,"消费者5").start();
}
}
class Resource
{
String name;
int count;
boolean flag=false;
public synchronized void produce(String name){
while(flag)
try{wait();}catch(Exception e){}
this.name=name;
System.out.println(Thread.currentThread().getName()+":生产一个商品,信息如下：");
System.out.println("产品名称："+name+"，产品编号："+(++count));
System.out.println("-----------------------------------------------------");
flag=true;
notifyAll();
}
public synchronized void consume(){
while(!flag)
try{wait();}catch(Exception e){}
System.out.println(Thread.currentThread().getName()+":某个商品被购买,信息如下：");
System.out.println("产品名称："+name+"，产品编号为："+count);
System.out.println("-----------------------------------------------------");
flag=false;
notifyAll();
}
}
class Producer implements Runnable
{
private final Resource r;
Producer(Resource r){
this.r=r;
}
public void run(){
while(true)
r.produce(creatRandomName());
}
public static String creatRandomName(){
String[] name={"加饭酒","茅台酒","21金维他","两面针","牙膏","电视机","计算机","桌子","衣服"};
return name[(int)(Math.random()*name.length)];
}
}
class Consumer implements Runnable
{
private final Resource r;
Consumer(Resource r){
this.r=r;
}
public void run(){
while(true)
r.consume();
}
}

复制代码

import java.util.concurrent.locks.*;
class ProducerConsumer2
{
public static void main(String[] args)
{
Resource r=new Resource();
Producer p=new Producer(r);
Consumer c=new Consumer(r);
new Thread(p,"生产者1").start();
new Thread(p,"生产者2").start();
new Thread(p,"生产者3").start();
new Thread(c,"消费者1").start();
new Thread(c,"消费者2").start();
new Thread(c,"消费者3").start();
new Thread(c,"消费者4").start();
new Thread(c,"消费者5").start();
}
}
class Resource
{
String name;
int count;
boolean flag=false;
private Lock lock=new ReentrantLock();
private Condition pro=lock.newCondition();
private Condition con=lock.newCondition();
public void produce(String name) throws InterruptedException {
lock.lock();
try{
while(flag)
pro.await();
this.name=name;
System.out.println(Thread.currentThread().getName()+":生产一个商品,信息如下：");
System.out.println("产品名称："+name+"，产品编号："+(++count));
System.out.println("-----------------------------------------------------");
flag=true;
con.signal();
}finally{
lock.unlock();
}
}
public void consume() throws InterruptedException {
lock.lock();
try{
while(!flag)
con.await();
System.out.println(Thread.currentThread().getName()+":某个商品被购买,信息如下：");
System.out.println("产品名称："+name+"，产品编号为："+count);
System.out.println("-----------------------------------------------------");
flag=false;
pro.signal();
}finally{
lock.unlock();
}
}
}
class Producer implements Runnable
{
private final Resource r;
Producer(Resource r){
this.r=r;
}
public void run(){
while(true){
try{
r.produce(creatRandomName());
}catch (InterruptedException e){
e.toString();
}
}
}
public static String creatRandomName(){
String[] name={"加饭酒","茅台酒","21金维他","两面针","牙膏","电视机","计算机","桌子","衣服"};
return name[(int)(Math.random()*name.length)];
}
}
class Consumer implements Runnable
{
private final Resource r;
Consumer(Resource r){
this.r=r;
}
public void run(){
while(true){
try{
r.consume();
}catch (InterruptedException e){
e.toString();
}
}
}
}

复制代码

import java.util.concurrent.locks.*;
class ProducerConsumer2
{
public static void main(String[] args)
{
Resource r=new Resource();
Producer p=new Producer(r);
Consumer c=new Consumer(r);
new Thread(p,"生产者1").start();
new Thread(p,"生产者2").start();
new Thread(p,"生产者3").start();
new Thread(c,"消费者1").start();
new Thread(c,"消费者2").start();
new Thread(c,"消费者3").start();
new Thread(c,"消费者4").start();
new Thread(c,"消费者5").start();
}
}
class commodity
{
String name;//产品名称
int number;//产品编号
commodity(int num){
this.name=creatRandomName();
this.number=num;
}
public static String creatRandomName(){
String[] name={"加饭酒","茅台酒","21金维他","两面针","牙膏","电视机","计算机","桌子","衣服"};
return name[(int)(Math.random()*name.length)];
}
}
class Resource
{
final commodity[] storehouse = new commodity[100];//仓库中的保存的货物
int total;//仓库中当前的货物总数
int proPointer;//生产者当前指针
int conPointer;//消费者当前指针
int count;//产品编号
private Lock lock=new ReentrantLock();
private Condition pro=lock.newCondition();
private Condition con=lock.newCondition();
public void produce() throws InterruptedException {
lock.lock();
try{
while(total==storehouse.length)
pro.await();
storehouse[proPointer]=new commodity(count++);
proPointer=(proPointer+1)%storehouse.length;
++total;
con.signal();
}finally{
lock.unlock();
}
}
public void consume() throws InterruptedException {
lock.lock();
try{
while(total==0)
con.await();
commodity temp=storehouse[conPointer];
conPointer=(conPointer+1)%storehouse.length;
--total;
System.out.println(Thread.currentThread().getName()+":某个商品被购买,信息如下：");
System.out.println("产品名称："+temp.name+"，产品编号为："+temp.number);
System.out.println("-----------------------------------------------------");
pro.signal();
}finally{
lock.unlock();
}
}
}
class Producer implements Runnable
{
private final Resource r;
Producer(Resource r){
this.r=r;
}
public void run(){
while(true){
try{
r.produce();
}catch (InterruptedException e){
e.toString();
}
}
}
}
class Consumer implements Runnable
{
private final Resource r;
Consumer(Resource r){
this.r=r;
}
public void run(){
while(true){
try{
r.consume();
}catch (InterruptedException e){
e.toString();
}
}
}
}

复制代码