利用java代码使用线程模拟餐厅的运营(必须用线程池): 服务员: 1. 餐厅有两位长期服务员 (核心线程) 2. 餐厅可以多招一个临时服务员 3. 临时服务员如果六十秒没活干就炒掉 4. 在餐厅门外只有十个位置让客人等待, 满了再来客直接抛异常 AbortPolicy 流程: 1. 每位服务员都需要去厨房取食物 2. 厨房需要预备食物让服务员领取 - 只有一位厨师预备食物 - 每秒随机炒一个菜, 最多可存十个菜 3. 每次只能一位服务员进厨房, 取得食物后打印出食物名称, 耗时三秒 进阶: 用Scanner 提供用户介面 1. 食客命令开始上菜, 菜品直接从厨房拿随机的, 不断运行 2. 食客手动不断点菜, 直至他想自己离开
时间: 2023-03-25 21:00:54 浏览: 171
以下是一个简单的Java代码,使用线程池模拟餐厅的运营:
```
import java.util.concurrent.*;
public class Restaurant {
private static final int MAX_WAITING_CUSTOMERS = 10;
private static final int MAX_FOODS = 10;
private static final int MAX_WAITING_TIME = 60;
private static final ExecutorService executor = Executors.newFixedThreadPool(3);
private static final BlockingQueue<String> foods = new ArrayBlockingQueue<>(MAX_FOODS);
private static final Semaphore kitchen = new Semaphore(1);
private static final Semaphore waitingCustomers = new Semaphore(MAX_WAITING_CUSTOMERS, true);
public static void main(String[] args) {
executor.execute(new Chef());
executor.execute(new Waiter());
executor.execute(new Waiter());
Scanner scanner = new Scanner(System.in);
while (true) {
System.out.println("请选择:1.开始上菜 2.点菜并离开");
int choice = scanner.nextInt();
if (choice == 1) {
executor.execute(new Customer());
} else if (choice == 2) {
break;
} else {
System.out.println("无效的选择,请重新输入");
}
}
executor.shutdown();
}
static class Chef implements Runnable {
@Override
public void run() {
while (true) {
try {
kitchen.acquire();
String food = cook();
foods.put(food);
System.out.println("厨师炒了一道" + food);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
kitchen.release();
}
}
}
private String cook() throws InterruptedException {
Thread.sleep((long) (Math.random() * 100));
return "菜品" + (int) (Math.random() * 100);
}
}
static class Waiter implements Runnable {
private boolean isTemporary;
public Waiter(boolean isTemporary) {
this.isTemporary = isTemporary;
}
public Waiter() {
this(false);
}
@Override
public void run() {
while (true) {
try {
waitingCustomers.acquire();
String food = foods.take();
Thread.sleep(300);
System.out.println("服务员" + (isTemporary ? "(临时)" : "") + "上了一道" + food);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
waitingCustomers.release();
}
}
}
}
static class Customer implements Runnable {
@Override
public void run() {
try {
waitingCustomers.acquire();
String food = foods.poll(MAX_WAITING_TIME, TimeUnit.SECONDS);
if (food == null) {
System.out.println("客人等待时间过长,离开了");
} else {
System.out.println("客人上了一道" + food);
}
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
waitingCustomers.release();
}
}
}
}
```
在这个代码中,我们使用了一个固定大小为3的线程池,其中有两个服务员和一个厨师。服务员和厨师都是Runnable接口的实现类,可以通过线程池来执行。
厨师使用一个Semaphore来控制厨房的并发访问,每次只能有一个服务员进入厨房取食物。厨师每秒钟随机炒一个菜,并将其放入一个BlockingQueue中,最多存放10个菜。
服务员使用一个Semaphore来控制等待的客人数量,最多只能有10个客人在餐厅门外等待。服务员从BlockingQueue中取出食物,并将其上菜,每次耗时3秒。
客人使用一个Semaphore来控制等待的客人数量,最多只能有10个客人在餐厅门外等待。客人从BlockingQueue中取出食物,如果等待时间超过60秒,则离开餐厅。
在进阶部分中,我们使用了Scanner来提供用户界面,客人可以选择开始上菜或点菜并离开。如果选择开始上菜,则会创建一个新的客人线程来等待上菜;如果选择点菜并离开,则会退出程序。
阅读全文