package ProConDemo;
//创建资源
public class Goods {
private String name;//计数器
private int count = 1;//创建一个标记
private boolean flag;//创建资源的生产行为
public synchronized void Sale(String name) {//判断标记
while(flag)//有资源就等待
try {wait();} catch (InterruptedException e) {e.printStackTrace();}//没有资源就生产
this.name = name +"----"+count; count++; System.out.println(Thread.currentThread().getName()+"生产了"+this.name);//生产完毕改标记
flag = true;//唤醒所有等待线程
notifyAll(); } //创建资源的消费行为 public synchronized void Buy() {//判断标记
while(!flag)//没有资源就等待
try {wait();} catch (InterruptedException e) {e.printStackTrace();}//有资源就消费
System.out.println(Thread.currentThread().getName()+"消费了"+this.name);//消费完毕改标记
flag = false;//唤醒所有等待线程
notifyAll(); }}
package ProConDemo;
//创建消费者任务类
public class Cou implements Runnable{
private Goods good; //将资源对象作为参数传入消费者的构造函数中 public Cou(Goods good) { this.good = good; } //覆盖run() public void run() { while(true) good.Buy(); }}package ProConDemo;
//创建生产者任务类
public class Pro implements Runnable{
private Goods good; //将资源对象作为参数传入生产者构造函数中 public Pro(Goods good) { this.good = good; }//覆盖run()
public void run() { while(true) good.Sale("面包"); }}//执行
package ProConDemo;
public class Demo {
public static void main(String[] args) {
// TODO Auto-generated method stub//创建资源对象
Goods good = new Goods(); //创建生产与消费任务对象 Pro pro = new Pro(good); Cou cou = new Cou(good); //创建线程，并将任务对象传入 Thread t0 = new Thread(pro); Thread t1 = new Thread(pro); Thread t2 = new Thread(cou); Thread t3 = new Thread(cou);//启动线程
t0.start(); t1.start(); t2.start(); t3.start(); }}