123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051 |
- package J20250801.homework.demo01;
- import java.util.Random;
- /**
- * @author WanJl
- * @version 1.0
- * @title Rider
- * @description 消费者---骑手
- * @create 2025/8/1
- */
- public class Rider implements Runnable{
- private OrderQueue orderQueue;
- private String name;
- public Rider() {
- }
- public Rider(OrderQueue orderQueue, String name) {
- this.orderQueue = orderQueue;
- this.name = name;
- }
- @Override
- public void run() {
- while (!Thread.currentThread().isInterrupted()){
- try {
- //取出订单
- Order order = orderQueue.take();
- //根据订单的类型处理订单
- int handleTime=0;
- switch (order.getType()){
- case "餐饮":
- handleTime=3000;
- break;
- case "生鲜":
- handleTime=5000;
- break;
- case "药品":
- handleTime=2000;
- break;
- }
- System.out.println("骑手"+name+"开始处理"+order.getType()+"订单,需要"+handleTime/1000+"秒");
- Thread.sleep(handleTime);
- System.out.println("骑手"+name+"完成处理"+order.getType()+"订单");
- } catch (InterruptedException e) {
- System.out.println("骑手"+name+"已停止工作....");
- }
- }
- }
- }
|