91 lines
2.4 KiB
Java
91 lines
2.4 KiB
Java
//: concurrency/Restaurant.java
|
|
// The producer-consumer approach to task cooperation.
|
|
import java.util.concurrent.*;
|
|
import static net.mindview.util.Print.*;
|
|
|
|
class Meal {
|
|
private final int orderNum;
|
|
public Meal(int orderNum) { this.orderNum = orderNum; }
|
|
@Override
|
|
public String toString() { return "Meal " + orderNum; }
|
|
}
|
|
|
|
class WaitPerson implements Runnable {
|
|
private Restaurant restaurant;
|
|
public WaitPerson(Restaurant r) { restaurant = r; }
|
|
@Override
|
|
public void run() {
|
|
try {
|
|
while(!Thread.interrupted()) {
|
|
synchronized(this) {
|
|
while(restaurant.meal == null)
|
|
wait(); // ... for the chef to produce a meal
|
|
}
|
|
print("Waitperson got " + restaurant.meal);
|
|
synchronized(restaurant.chef) {
|
|
restaurant.meal = null;
|
|
restaurant.chef.notifyAll(); // Ready for another
|
|
}
|
|
}
|
|
} catch(InterruptedException e) {
|
|
print("WaitPerson interrupted");
|
|
}
|
|
}
|
|
}
|
|
|
|
class Chef implements Runnable {
|
|
private Restaurant restaurant;
|
|
private int count = 0;
|
|
public Chef(Restaurant r) { restaurant = r; }
|
|
@Override
|
|
public void run() {
|
|
try {
|
|
while(!Thread.interrupted()) {
|
|
synchronized(this) {
|
|
while(restaurant.meal != null)
|
|
wait(); // ... for the meal to be taken
|
|
}
|
|
if(++count == 10) {
|
|
print("Out of food, closing");
|
|
restaurant.exec.shutdownNow();
|
|
}
|
|
printnb("Order up! ");
|
|
synchronized(restaurant.waitPerson) {
|
|
restaurant.meal = new Meal(count);
|
|
restaurant.waitPerson.notifyAll();
|
|
}
|
|
TimeUnit.MILLISECONDS.sleep(100);
|
|
}
|
|
} catch(InterruptedException e) {
|
|
print("Chef interrupted");
|
|
}
|
|
}
|
|
}
|
|
|
|
public class Restaurant {
|
|
Meal meal;
|
|
ExecutorService exec = Executors.newCachedThreadPool();
|
|
WaitPerson waitPerson = new WaitPerson(this);
|
|
Chef chef = new Chef(this);
|
|
public Restaurant() {
|
|
exec.execute(chef);
|
|
exec.execute(waitPerson);
|
|
}
|
|
public static void main(String[] args) {
|
|
new Restaurant();
|
|
}
|
|
} /* Output:
|
|
Order up! Waitperson got Meal 1
|
|
Order up! Waitperson got Meal 2
|
|
Order up! Waitperson got Meal 3
|
|
Order up! Waitperson got Meal 4
|
|
Order up! Waitperson got Meal 5
|
|
Order up! Waitperson got Meal 6
|
|
Order up! Waitperson got Meal 7
|
|
Order up! Waitperson got Meal 8
|
|
Order up! Waitperson got Meal 9
|
|
Out of food, closing
|
|
WaitPerson interrupted
|
|
Order up! Chef interrupted
|
|
*///:~
|