通过生产者消费者模式例子讲解Java基类方法wait、notify、notifyAll

/**
* 消费者
* Created by Wiki on 16/1/28.
*/
public class Customer implements Runnable {
private String name;
private Channel channel;

public Customer(String name, Channel channel) {
this.name = name;
this.channel = channel;
}

@Override
public void run() {
while (true) {
Good good = channel.get();
if (good != null) {
System.out.println(name + " 获得商品:" + good.getName());
} else {
synchronized (channel) {
try {
System.out.println(name + " 进入等待");
channel.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}

/**
* 生产者
* Created by Wiki on 16/1/28.
*/
public class Producer implements Runnable {
private static volatile int goodNumber = 0;

private String name;
private Channel channel;

public Producer(String name, Channel channel) {
this.name = name;
this.channel = channel;
}

@Override
public void run() {
while (true) {
int sleep = new Random().nextInt(2000);
try {
Thread.sleep(sleep);
} catch (InterruptedException e) {
e.printStackTrace();
}
Good good = new Good("商品-编号" + (++goodNumber));
System.out.println(name + " 生产商品:" + good.getName());
channel.put(good);
}
}
}

/**
* 商品
* Created by Wiki on 16/1/28.
*/
public class Good {
private String name;

public Good(String name) {
this.name = name;
}

public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}
}

/**
* 消费通道
* Created by Wiki on 16/1/28.
*/
public class Channel {
private Queue<Good> goodList = new LinkedList<>();

public synchronized Good get() {
if (goodList.size() == 0) {
return null;
}
Good good = goodList.remove();
return good;
}

public synchronized void put(Good good) {
goodList.add(good);
//        notifyAll();
notify();
}
}

public class Main {

public static void main(String[] args) {
Channel channel = new Channel();
new Thread(new Producer("生产者1", channel)).start();
new Thread(new Producer("生产者2", channel)).start();
new Thread(new Producer("生产者2", channel)).start();

new Thread(new Customer("消费者1", channel)).start();
new Thread(new Customer("消费者2", channel)).start();
new Thread(new Customer("消费者3", channel)).start();
}
}