第七十篇 从餐厅后厨到电影院选座:生活场景拆解Java并发编程核心

目录

    • 一、并发基础:餐厅后厨的协作艺术
      • 1.1 厨师与线程(Thread)
      • 1.2 共享资源竞争:唯一的炒锅
      • 1.3 线程状态转换:厨师工作流
    • 二、线程同步:电影院选座中的锁机制
      • 2.1 同步锁(synchronized):选座系统
      • 2.2 显式锁(ReentrantLock):VIP选座通道
    • 三、线程协作:咖啡厅的点单取餐系统
      • 3.1 生产者-消费者模式
      • 3.2 CountDownLatch:旅行团集合点
    • 四、并发工具进阶:超市收银系统
      • 4.1 线程池(ExecutorService):收银通道管理
      • 4.2 ConcurrentHashMap:实时库存系统
    • 五、避坑指南:并发编程常见陷阱
      • 5.1 死锁场景:十字路口的四辆车
      • 5.2 线程饥饿:永远轮不到的普通会员
      • 5.3 内存可见性:过期的餐厅菜单
    • 六、性能优化:电影院排片策略
      • 6.1 锁粒度控制
      • 6.2 无锁编程:原子类操作
    • 结语:构建高效并发系统

想象一家繁忙的餐厅后厨:主厨指挥多个厨师同时处理订单,服务员在取餐口等待出菜,新订单不断涌入——这正是Java并发编程的完美生活映射。本文将用你熟悉的日常场景,带你掌握高并发系统的构建之道。

一、并发基础:餐厅后厨的协作艺术

1.1 厨师与线程(Thread)

每个厨师就像一个线程

// 厨师线程类
class ChefThread extends Thread {@Overridepublic void run() {System.out.println(Thread.currentThread().getName() + "开始烹饪");// 模拟烹饪耗时try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); }}
}// 启动5个厨师线程
public static void main(String[] args) {for (int i=1; i<=5; i++) {new ChefThread().start();}
}

1.2 共享资源竞争:唯一的炒锅

当多个厨师争抢**同一个炒锅(共享资源)**时:

// 共享炒锅资源
class Wok {private boolean inUse = false;// 加锁使用炒锅public synchronized void use(String chefName) {if(inUse) return;inUse = true;System.out.println(chefName + "占用炒锅");}
}

1.3 线程状态转换:厨师工作流

线程状态厨师状态触发条件
RUNNABLE正在切菜获取到食材
BLOCKED等待炒锅其他厨师占用炒锅
WAITING等待服务员传菜菜品完成但服务员未就位
TIMED_WAITING定时查看烤箱设置定时器监控烘焙进度

二、线程同步:电影院选座中的锁机制

2.1 同步锁(synchronized):选座系统

场景:多人同时在线选座,避免座位重复出售

class Cinema {private boolean[] seats = new boolean[100]; // 100个座位// 同步选座方法public synchronized boolean bookSeat(int seatNo) {if(!seats[seatNo]) {seats[seatNo] = true;System.out.println(Thread.currentThread().getName() + "成功预订座位" + seatNo);return true;}return false;}
}

2.2 显式锁(ReentrantLock):VIP选座通道

场景:提供超时等待功能,避免无限期阻塞

private ReentrantLock lock = new ReentrantLock();public boolean vipBookSeat(int seatNo) {try {// 尝试在1秒内获取锁if(lock.tryLock(1, TimeUnit.SECONDS)) {if(!seats[seatNo]) {seats[seatNo] = true;return true;}}} catch (InterruptedException e) {e.printStackTrace();} finally {if(lock.isHeldByCurrentThread()) {lock.unlock();}}return false;
}

三、线程协作:咖啡厅的点单取餐系统

3.1 生产者-消费者模式

场景:顾客(生产者)下单,咖啡师(消费者)制作

BlockingQueue<Order> orderQueue = new ArrayBlockingQueue<>(10);// 顾客下单
class Customer implements Runnable {public void run() {orderQueue.put(new Order()); // 队列满时阻塞}
}// 咖啡师制作
class Barista implements Runnable {public void run() {while(true) {Order order = orderQueue.take(); // 队列空时阻塞makeCoffee(order);}}
}

3.2 CountDownLatch:旅行团集合点

场景:导游等待所有游客到齐才发车

CountDownLatch latch = new CountDownLatch(10); // 10人旅行团// 游客线程
class Tourist extends Thread {public void run() {System.out.println(getName() + "到达集合点");latch.countDown();}
}// 导游线程
class Guide extends Thread {public void run() {latch.await(); // 等待所有游客System.out.println("所有游客到齐,发车!");}
}

四、并发工具进阶:超市收银系统

4.1 线程池(ExecutorService):收银通道管理

// 开放4个收银通道
ExecutorService cashiers = Executors.newFixedThreadPool(4); // 顾客排队结账
for(int i=0; i<20; i++) {cashiers.execute(() -> {System.out.println("顾客在"+Thread.currentThread().getName()+"结账");});
}cashiers.shutdown(); // 营业结束关闭收银台

4.2 ConcurrentHashMap:实时库存系统

ConcurrentHashMap<String, Integer> inventory = new ConcurrentHashMap<>();// 多个收银台同时更新库存
inventory.compute("可乐", (k, v) -> v == null ? -1 : v-1);

五、避坑指南:并发编程常见陷阱

5.1 死锁场景:十字路口的四辆车

条件:四个方向的车都等待对方先通行
解决方案:规定通行优先级(锁排序)

5.2 线程饥饿:永远轮不到的普通会员

现象:VIP会员总是优先办理业务
修复:使用公平锁(Fair Lock)

5.3 内存可见性:过期的餐厅菜单

// 错误示例:其他线程可能看不到menuChanged更新
boolean menuChanged = false; // 正确做法:使用volatile保证可见性
volatile boolean menuChanged = true;

六、性能优化:电影院排片策略

6.1 锁粒度控制

// 粗粒度锁:锁整个影厅(性能差)
public synchronized void bookSeats(List<Integer> seats) {...}// 细粒度锁:只锁选定座位(推荐)
public void bookSeats(List<Integer> seats) {for (int seat : seats) {synchronized (seatLocks[seat]) {// 处理单个座位}}
}

6.2 无锁编程:原子类操作

AtomicInteger availableTickets = new AtomicInteger(100);// 多个窗口同时售票
public boolean sellTicket() {int current = availableTickets.get();if(current > 0) {return availableTickets.compareAndSet(current, current-1);}return false;
}

结语:构建高效并发系统

Java并发编程如同管理繁忙的餐厅后厨:

  1. 合理分工:使用线程池控制工作线程数量
  2. 资源协调:通过锁机制避免资源冲突
  3. 流程优化:利用阻塞队列实现生产者-消费者模式
  4. 实时同步:采用原子操作保证数据一致性
新订单
订单队列
线程池
厨师线程1
厨师线程2
厨师线程3
完成菜品
出餐口

掌握这些生活化的并发模式,你将能构建出如米其林餐厅后厨般高效运转的Java应用系统。记住:优秀的并发程序不是没有锁,而是让线程排队时间最小化,协作效率最大化

🎯下期预告:《Java 线程池》
💬互动话题:第一要有志,第二要有识,第三要有恒
🏷️温馨提示:我是[随缘而动,随遇而安], 一个喜欢用生活案例讲技术的开发者。如果觉得有帮助,点赞关注不迷路🌟

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.pswp.cn/news/907857.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

嵌入式学习--江协stm32day1

失踪人口回归了&#xff0c;stm32的学习比起51要慢一些&#xff0c;因为涉及插线&#xff0c;可能存在漏插&#xff0c;不牢固等问题。 相对于51直接对寄存器的设置&#xff0c;stm32因为是32位修改起来比较麻烦&#xff0c;江协课程是基于标准库的&#xff0c;是对封装函数进…

vue+elementUi+axios实现分页(MyBatis、Servlet)

vueelementUiaxios实现分页 文章目录 vueelementUiaxios实现分页1.代码实现【HTML】**【Servlet层】****【Service层】****【Dao层】** 2.总结步骤3.实现要点4.注意事项4.注意事项 注&#xff1a;此项目 前端为 html、 后端采用 mybatis、servlet实现 1.代码实现 【HTML】…

vue-10( 动态路由匹配和路由参数)

动态路由匹配和路由参数 动态路由匹配是 Vue Router 的一个强大功能&#xff0c;它允许你创建灵活且可重用的路由。您可以使用参数来捕获 URL 的动态段&#xff0c;而不是为每个可能的值定义特定路由。这在处理具有唯一标识符的资源&#xff08;如用户配置文件、产品详细信息或…

劫持进程注入

劫持进程注入和远程线程注入的区别就是 远程线程注入是向一个正在运行中的进程注入 而劫持进程注入则是自己打开一个进程(以挂起的方式) 然后再进行注入的操作 这样做的原因是当进程在挂起的状态时他的所有线程都是处于未启用的阶段 这样就可以避免目标进程的反注入线程的…

uni-app学习笔记二十--pages.json页面路由pages设置

uni-app 通过 pages 节点配置应用由哪些页面组成&#xff0c;pages 节点接收一个数组&#xff0c;数组每个项都是一个对象&#xff0c;其属性值如下&#xff1a; 属性类型默认值描述pathString配置页面路径styleObject配置页面窗口表现&#xff0c;配置项参考下方 pageStylene…

VScode编译调试debug,gpu的cuda程序,Nsight

进行下面操作的前提是&#xff0c;我们的环境已经能跑简单的CUDA程序了。 一、安装Nsight 二、创建launch.json文件 {"version": "0.2.0","configurations": [{"name": "CUDA C: Launch","type": "cuda-gdb…

链表题解——合并两个有序链表【LeetCode】

1. 算法思路 这段代码的核心思想是 合并两个有序链表。具体步骤如下&#xff1a; 初始化哨兵节点&#xff1a; 创建一个哨兵节点 dummy&#xff0c;用于简化链表操作&#xff0c;避免处理头节点的特殊情况。使用指针 cur 指向 dummy&#xff0c;用于构建新的链表。 遍历两个链…

K8S集群主机网络端口不通问题排查

一、环境&#xff1a; k8s: v1.23.6 docker: 20.10.14 问题和故障现象&#xff1a;devops主机集群主机节点到端口8082不通&#xff08;网络策略已经申请&#xff0c;并且网络策略已经实施完毕&#xff09;&#xff0c;而且网络实施人员再次确认&#xff0c;网络策…

qemu安装risc-V 64

参考这篇文章https://developer.aliyun.com/article/1323996&#xff0c;其中在wsl下面安装可能会报错环境变量中有空格。 # clean_path.sh#!/bin/bash# 备份旧 PATH OLD_PATH"$PATH"# 过滤掉包含空格、制表符、换行的路径 CLEAN_PATH"" IFS: read -ra PA…

python爬虫:RoboBrowser 的详细使用

更多内容请见: 爬虫和逆向教程-专栏介绍和目录 文章目录 一、RoboBrowser概述1.1 RoboBrowser 介绍1.2 安装 RoboBrowser1.3 与类似工具比较二、基本用法2.1 创建浏览器对象并访问网页2.2 查找元素2.3 填写和提交表单三、高级功能3.1 处理文件上传3.2 处理JavaScript重定向3.3…

CTFSHOW-WEB-36D杯

给你shell 这道题对我这个新手还是有难度的&#xff0c;花了不少时间。首先f12看源码&#xff0c;看到?view_source&#xff0c;点进去看源码 <?php //Its no need to use scanner. Of course if you want, but u will find nothing. error_reporting(0); include "…

CentOS_7.9 2U物理服务器上部署系统简易操作步骤

近期单位网站革新&#xff0c;鉴于安全加固&#xff0c;计划将原有Windows环境更新到Linux-CentOS 7.9&#xff0c;这版本也没的说&#xff08;绝&#xff09;了&#xff08;版&#xff09;官方停止更新&#xff0c;但无论如何还是被sisi的牵挂着这一大批人&#xff0c;毕竟从接…

LVS-DR高可用-Keepalived

目录 Keepalved双机热备 核心概念 关键组件 工作流程 实例环境 配置keepalived Web服务器配置 Keepalved双机热备 Keepalived双机热备是一种基于VRRP&#xff08;Virtual Router Redundancy Protocol&#xff0c;虚拟路由冗余协议&#xff09;实现的高可用性解决方案&am…

Polar编译码(SCL译码)和LDPC编译码(BP译码)的matlab性能仿真,并对比香农限

目录 1.算法仿真效果 2.算法涉及理论知识概要 2.1香农极限 2.2 Polar码编译码原理与SCL译码 2.3 LDPC码编译码原理与BP译码 3.MATLAB核心程序 4.完整算法代码文件获得 1.算法仿真效果 matlab2024b仿真结果如下&#xff08;完整代码运行后无水印&#xff09;&#xff1a…

AI 产品的 MVP 构建逻辑:Prompt 工程 ≠ 产品工程?(实战增补篇)

一. 系统思维&#xff1a;产品工程的全局把控&#xff08;实战增补篇&#xff09; 1. 某智能风控系统的弹性架构实践 某消费金融公司在开发「30 秒极速贷」产品时&#xff0c;面临两大挑战&#xff1a; Prompt 优化困境&#xff1a;传统风控模型依赖 “提取用户信用报告关键…

Unity程序集

对于Unity的程序集&#xff0c;具体内容可以参考Unity官方文档&#xff0c;程序集定义 - 预定义程序集 比如Unity的默认程序集&#xff0c;Assembly-CSharp.dll&#xff0c;还有其他的比如 Assembly-CSharp-Editor.dll&#xff0c;Assembly-CSharp-firstpass.dll 没有指定或…

【架构艺术】平衡技术架构设计和预期的产品形态

近期笔者因为工作原因&#xff0c;开始启动team内部部分技术项目的重构。在事情启动的过程中&#xff0c;内部对于这件事情的定性和投入有一些争论&#xff0c;但最终还是敲定了下来。其中部分争论点主要在于产品形态&#xff0c;因为事情涉及到跨部门合作&#xff0c;所以产品…

React和原生事件的区别

一、核心差异对比表 维度原生事件React 事件绑定语法HTML 属性&#xff08;onclick&#xff09;或 DOM API&#xff08;addEventListener&#xff09;JSX 中使用驼峰式属性&#xff08;onClick&#xff09;绑定位置直接绑定到具体 DOM 元素统一委托到根节点&#xff08;React …

大模型-modelscope下载和使用chatglm3-6b模型

前言 由于官方chatglm3-6b大模型文件下载比较慢&#xff0c;找到国内modelscope代替方案 1.SDK下载 pip install modelscope2.下载大模型文件 ✅方法1:通过pip下载 1.安装 setuptools 在当前使用的 Python 环境中安装 setuptools pip install setuptools2.通过如下命令安…

【unity游戏开发——编辑器扩展】AssetDatabase公共类在编辑器环境中管理和操作项目中的资源

注意&#xff1a;考虑到编辑器扩展的内容比较多&#xff0c;我将编辑器扩展的内容分开&#xff0c;并全部整合放在【unity游戏开发——编辑器扩展】专栏里&#xff0c;感兴趣的小伙伴可以前往逐一查看学习。 文章目录 前言一、AssetDatabase常用API1、创建资源1.1 API1.2 示例 …