【Java多线程】-生产者与消费者

package org.iti.thread;

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

public class ThreadDemo_3 {
public static void main(String args[]) {
Plate plate = new Plate();
for (int i = 0; i < 15; i++) {
new Thread(new AddThread(plate)).start();
new Thread(new GetThread(plate)).start();
}
}
}

class AddThread implements Runnable {
private Plate plate;
private Object apple = new Object();

public AddThread(Plate plate) {
this.plate = plate;
}

public void run() {
plate.putApple(apple);
}
}

class GetThread implements Runnable {
private Plate plate;

public GetThread(Plate plate) {
this.plate = plate;
}

public void run() {
plate.getApple();
}
}

class Plate {
List<Object> apples = new ArrayList<Object>();

public synchronized Object getApple() {
while (apples.size() == 0) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
Object apple = apples.get(0);
apples.remove(apple);
notify();
System.out.println("拿到苹果");
return apple;
}

public synchronized void putApple(Object apple) {
while (apples.size() > 3) {
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
apples.add(apple);
notify();
System.out.println("放入苹果");
}

}