Main.java 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. package J20250801.homework.demo01;
  2. /**
  3. * @author WanJl
  4. * @version 1.0
  5. * @title Main
  6. * @description 主程序--测试
  7. * @create 2025/8/1
  8. */
  9. public class Main {
  10. public static void main(String[] args) throws InterruptedException {
  11. OrderQueue queue=new OrderQueue();
  12. //3个商家
  13. Thread rest1=new Thread(new Restaurant(queue,"吴AA"));
  14. Thread rest2=new Thread(new Restaurant(queue,"赵BB"));
  15. //Thread rest3=new Thread(new Restaurant(queue,"王CC"));
  16. //2个骑手
  17. Thread rider1=new Thread(new Rider(queue,"李11"));
  18. Thread rider2=new Thread(new Rider(queue,"张22"));
  19. //启动所有线程
  20. rest1.start();
  21. rest2.start();
  22. //rest3.start();
  23. rider1.start();
  24. rider2.start();
  25. //运行50秒后终止
  26. Thread.sleep(50000);
  27. //中断所有线程
  28. rest1.interrupt();
  29. rest2.interrupt();
  30. //rest3.interrupt();
  31. rider1.interrupt();
  32. rider2.interrupt();
  33. System.out.println("系统运行结束,剩余未处理订单:"+queue.size());
  34. }
  35. }