多线程的问题求大神进来解读 - 黑马程序员技术交流社区

package Packs;
import java.io.IOException;
import java.util.*;
public class SR
{
public static void main(String[]args) throws IOException
{
ArrayList<Goods> al=new ArrayList<Goods>();
Room r=new Room(100,al);//库存上限
Producer pd=new Producer(al,r);//生产者
Customer ct=new Customer(al,r);//消费者
//输入货物
Thread t1=new Thread(pd); //创建生产者进程
Thread t2=new Thread(ct);//创建消费者进程1
Thread t3=new Thread(ct);//创建消费者进程2
t1.start();
t2.start();
t3.start();
//打印货物
}
}
class Customer implements Runnable
{
private ArrayList<Goods>al=null;
private Room r;
public Customer(ArrayList<Goods>al,Room r)
{
this.r=r;
this.al=al;
}
public void run()
{
synchronized(r)
{
if(!(r.flag))
{
try {
r.wait();
} catch (InterruptedException e)
{
// TODO Auto-generated catch block
e.printStackTrace();
}
}
System.out.println("\n取货员来了！！！");
Random rm=new Random();
while(!al.isEmpty())//假如集合不空的话，我就随机打印，然后移除打印对象
{
int m=rm.nextInt(al.size());
if(al.get(m)!=null)
{
System.out.println(Thread.currentThread().getName()+"——"+al.get(m).name+"\t"+al.get(m).price+"元");
Thread.yield();
al.remove(m);
}
}
r.flag=false;
r.notify();
}
}
}
class Producer implements Runnable
{
ArrayList<Goods> al=null;
Room r=null;
Producer(ArrayList<Goods> al,Room r)
{
this.al=al;
this.r=r;
}
public void Input() throws IOException//手动输入的部分，但是便于测试没有启动
{
System.out.println("请存入商品的名称和价格以空格分隔，回车确认");
BufferedReader bufr=new BufferedReader(new InputStreamReader(System.in));
String line=null;
int num=0;
while((line=bufr.readLine())!=null)
{
if("over".equals(line))
{
break;
}
String[] msg=line.split(" ");
if(num<=r.max-1)
{
try
{
al.add(new Goods(msg[0],new Float(msg[1])));
}
catch(Exception e)
{
System.out.println("存在非法输入");
}
num++;
}
}
}
public void produce()//产生随机对象，存入集合
{
System.out.println("自动存入货物");
Random rm=new Random();
while(al.size()!=r.max)
{
int m=rm.nextInt(100);
int n=rm.nextInt(100);
al.add(new Goods(String.valueOf(m),new Float(n)));
}
}
public void run()
{
synchronized(r)
{
if(r.flag)
{
try {
r.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
//Input();
produce();
if(r.isFull())
System.out.println("仓库已满不能存货");
r.showGoods();
r.flag=true;
r.notifyAll();
}
}
}
class Room
{
public int max;
private ArrayList<Goods>al=null;
public boolean flag;
public Room(int max,ArrayList<Goods>al)
{
this.max=max;
this.al=al;
flag=false;
}
public boolean isFull()
{
flag=false;
if(al.size()==max)
flag=true;
return flag;
}
public void showGoods()
{
int num=1;
if(!al.isEmpty())
{
System.out.println("已存入货物");
System.out.println("编号\t名称\t价格");
}
Iterator it=al.iterator();
while(it.hasNext())
{
Object obj=it.next();
Goods p=(Goods)obj;
System.out.println("("+num+")\t"+p.name+"\t"+p.price+"元");
num++;
}
}
}
class Goods
{
public String name;
public float price;
public Goods(String name,float price )
{
this.name=name;
this.price=price;
}
public Goods()
{
}
}

复制代码