java线程之一生产者与消费者

package com.itcast.threadinfo;

//生产者与消费者
//(1-1)
public class Demo1 {

?public static void main(String[] args) {

??proDemo p = new proDemo();
??Procedure pp = new Procedure(p);
??Customer cc = new Customer(p);
??Thread t1 = new Thread(pp);
??Thread t2 = new Thread(cc);
??t1.start();
??t2.start();

?}

}

class proDemo {
?private String name;
?private int count;
?private boolean flag = false;

?public synchronized void procudeInfo(String name) {
??if (flag)
???try {
????this.wait();
???} catch (InterruptedException e) {
????// TODO Auto-generated catch block
????e.printStackTrace();
???}
??this.name = name + count;
??count++;
??System.out.println("生成者..."+this.name);
??flag = true;
??notify();
?}

?public synchronized void getcustomer() {
??if (!flag)
???try {
????this.wait();
???} catch (InterruptedException e) {
????// TODO Auto-generated catch block
????e.printStackTrace();
???}
???System.out.println("消费者..."+name);
??flag = false;
??notify();
?}
}

class Procedure implements Runnable {
?proDemo d;

?public Procedure(proDemo d) {
??this.d = d;
?}

?@Override
?public void run() {
??while (true) {
???d.procudeInfo("烤鸭");
??}
?}
}

class Customer implements Runnable {
?proDemo d;

?public Customer(proDemo d) {
??this.d = d;
?}

?public void run() {
??while (true) {
???d.getcustomer();
??}
?}

}