Producer &Consumer

package jms;

import java.util.ArrayList;
import java.util.List;

public class JmsDemo2 {

static final int threadInitNumber = 1;

public static void main(String[] args) {

Store store = new JmsDemo2().new Store();

List<Thread> producers = new ArrayList<Thread>();
List<Thread> consumers = new ArrayList<Thread>();
for(int i=0;i<threadInitNumber;i++){
producers.add(new Thread(new JmsDemo2().new Producer(store),"【第" + (i+1) +"个生产者】"));
consumers.add(new Thread(new JmsDemo2().new Consumer(store),"【第" + (i+1) +"个消费者】"));
}

for(int i=0;i<threadInitNumber;i++){
producers.get(i).start();
consumers.get(i).start();
}
}

class Store {

private List<String> entry = new ArrayList<String>();

private boolean isProducer = true;

public synchronized void push(String msg){
while(isProducer){
entry.add(msg);
System.out.println("生产数据" + msg + "等待消费，当前队列深度" + entry.size());
isProducer = false;
try {
this.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("push end isProducer" + isProducer);
}
notifyAll();

}

public synchronized void get(){
while(!isProducer){
if(entry.isEmpty()){
System.out.println("当前队列为空，等待生产...");
}
System.out.println("消费" + entry.remove(entry.size()-1) + "等待生产，当前队列深度" + entry.size());
isProducer = true;
try {
this.wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("get end isProducer" + isProducer);
}
notifyAll();
}
}

class Producer implements Runnable{

Store store;

public Producer(Store store) {
super();
this.store = store;
}

@Override
public void run() {
store.push(Thread.currentThread().getName());
}
}

class Consumer implements Runnable{

Store store;

public Consumer(Store store) {
super();
this.store = store;
}

@Override
public void run() {
store.get();
}
}

}