package com.imooc.queue;

public class Consumer implements Runnable{
private Queue q;

public Consumer() {
}
public Consumer(Queue q) {
this.setQ(q); 
}

public Queue getQ() {
return q;
}

public void setQ(Queue q) {
this.q = q;
}

@Override
public void run() {
while(true) {
this.getQ().getN();
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}


package com.imooc.queue;

public class Producer implements Runnable{
private Queue q;
public Producer() {
}
public Producer(Queue q) {
this.setQ(q); 
}

public Queue getQ() {
return q;
}

public void setQ(Queue q) {
this.q = q;
}

@Override
public void run() {
int i=0;
while(true) {
this.getQ().setN(i++); 
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

}



package com.imooc.queue;

public class Queue {
private int n;
boolean flag = false;
public Queue() {
}

public synchronized int getN() {
if(!flag) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("消费："+n);
flag = false; //消费完毕，容器中没有数据
notifyAll();
return n;
}

public synchronized void setN(int n) {
if(flag) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("生产："+this.getN());
this.n = n;
flag = true; // 生产完毕，容器中已经有数据
notifyAll();
}

}


package com.imooc.queue;

public class Test {

public static void main(String[] args) {
Queue queue = new Queue();
new Thread(new Producer(queue)).start();
new Thread(new Consumer(queue)).start();
}

}