第16章 Single Thread Execution设计模式(Java高并发编程详解:多线程与系统设计)

简单来说, Single Thread Execution就是采用排他式的操作保证在同一时刻只能有一个线程访问共享资源。

1.机场过安检

1.1非线程安全

先模拟一个非线程安全的安检口类,旅客(线程)分别手持登机牌和身份证接受工作人员的检查,示例代码如所示。

public class FlightSecurity {private int count = 0;// 登机牌private String boardingPass = "null";// 身份证private String idCard = "null";public void pass(String boardingPass, String idCard) {this.boardingPass = boardingPass;this.idCard = idCard;this.count++;}private void check() {// 简单的测试,当登机牌和身份证首字母不相同时则表示检查不通过if ( boardingPass.charAt(0) != idCard.charAt(0)) throw new RuntimeException("======Exception=====" + toString());}@Overridepublic String toString() {return "FlightSecurity{" +"count=" + count +", boardingPass='" + boardingPass + '\'' +", idCard='" + idCard + '\'' +'}';}
}

Flight Security比较简单, 提供了一个pass方法, 将旅客的登机牌和身份证传递给pass方法, 在pass方法中调用check方法对旅客进行检查, 检查的逻辑也足够的简单, 只需要检测登机牌和身份证首字母是否相等(当然这样在现实中非常不合理,但是为了使测试简单我们约定这么做),我们看代码所示的测试.

public class FlightSecurityTest {// 旅客线程static class Passengers extends Thread {// 机场安检类private final FlightSecurity flightSecurity;// 旅客的身份证private final String idCard;// 旅客的登机牌private final String boardingPass;// 构造旅客是传入身份证,登机牌以及机场安检类public Passengers(FlightSecurity flightSecurity, String idCard, String boardingPass) {this.flightSecurity = flightSecurity;this.idCard = idCard;this.boardingPass  = boardingPass;}@Overridepublic void run() {while(true) {flightSecurity.pass(boardingPass, idCard);}}}public static void main(String[] args) {// 定义三个旅客,身份证和登机牌首字母均相同final FlightSecurity flightSecurity = new FlightSecurity();new Passengers(flightSecurity, "A1234","AF1234").start();new Passengers(flightSecurity, "B1234", "BF1234").start();new Passengers(flightSecurity,"C1234", "CF1234").start();}
}

首字母相同检查不能通过和首字母不相同检查不能通过,为什么会出现这样的情况呢?首字母相同却不能通过?更加奇怪的是传入的参数明明全都是首字母相同的,为什么会出现首字母不相同的错误呢?

1.2 问题分析

(1)首字母相同却未通过检查

图所示的为首字母相同却无法通过安检的分析过程。

2

(2)为何出现首字母不相同的情况

明明传入的身份证和登机牌首字母都相同,可为何在运行的过程中会出现首字母不相同的情况,下面我们也通过图示的方式进行分析,如图所示。

1.3 线程安全

1.1节中出现的问题说到底就是数据同步的问题, 虽然线程传递给pass方法的两个参数能够百分之百地保证首字母相同, 可是在为FlightSecurity中的属性赋值的时候会出现多个线程交错的情况,结合我们在第一部分第4章的所讲内容可知,需要对共享资源增加同步保护,改进代码如下:

    public synchronized void pass(String boardingPass, String idCard) {this.boardingPass = boardingPass;this.idCard = idCard;this.count++;}

何时适合使用single thread execution模式呢?答案如下。

  • 多线程访问资源的时候, 被synchronized同步的方法总是排他性的。
  • 多个线程对某个类的状态发生改变的时候, 比如Flight Security的登机牌以及身份证。

2.吃面问题

2.1吃面引起的死锁

虽然使用synchronized关键字可以保证single thread execution, 但是如果使用不得当则会导致死锁的情况发生,比如A手持刀等待B放下叉,而B手持叉等待A放下刀,示例代码如所示。

public class EatNoodleThread extends Thread {private final String name;// 左手边的餐具private final Tableware leftTool;// 右手边的餐具private final Tableware rightTool;public EatNoodleThread(String name, Tableware leftTool, Tableware rightTool) {this.name = name;this.leftTool = leftTool;this.rightTool = rightTool;}@Overridepublic void run() {while (true) {this.eat();}}// 吃面条的过程private void eat() {synchronized (leftTool) {System.out.println(name + " take up" + leftTool + "left");synchronized (rightTool) {System.out.println(name + "take up " + rightTool + "right");}System.out.println(name + " put down " + leftTool);}}public static void main(String[] args) {Tableware fork = new Tableware("fork");Tableware knife = new Tableware("knife");new EatNoodleThread("A", fork, knife).start();new EatNoodleThread("B", knife, fork).start();}
}

2.2 解决吃面引起的死锁问题

为了解决交叉锁的情况,我们需要将刀叉进行封装,使刀叉同属于一个类中,改进代码如所示

public class EatNoodleThread1 extends Thread{private final String name;private final TablewarePair tablewarePair;public EatNoodleThread1(String name, TablewarePair tablewarePair) {this.name = name;this.tablewarePair = tablewarePair;}@Overridepublic void run() {while(true) {this.eat();}}private void eat() {synchronized (tablewarePair) {System.out.println("eatting");}}}

2.3哲学家吃面问题

哲学家吃面是解释操作系统中多个进程竞争资源的经典问题,每个哲学家的左右手都有吃面用的刀叉,但是不足以同时去使用,比如A哲学家想要吃面,必须拿起左手边的叉和右手边的刀,但是有可能叉和刀都被其他哲学家拿走使用,或者是手持刀等待别人放下叉等容易引起死锁的问题。

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

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

相关文章

OSPF基础(2):数据包详解

OSPF数据包(可抓包) OSPF报文直接封装在IP报文中,协议号89 头部数据包内容: 版本(Version):对于OSPFv2,该字段值恒为2(使用在IPV4中);对于OSPFv3,该字段值恒为3(使用在IPV6中)。类型(Message Type):该OSPF报文的类型。…

MAC 安装mysql全过程记录

4.然后等待下载吧,(下载中。。。。),好了,网速的问题,半个小时终于下载好了,开始安装吧。 5.得到如下安装包,mac下也是双击直接下载,来,我们来看看下载的过程…

神经网络常见激活函数 1-sigmoid函数

sigmoid 1 函数求导 sigmoid函数 σ ( x ) 1 1 e ( − x ) \sigma(x) \frac{1}{1e^{(-x)}} σ(x)1e(−x)1​ sigmoid函数求导 d d x σ ( x ) d d x ( 1 1 e − x ) e − x ( 1 e − x ) 2 ( 1 e − x ) − 1 ( 1 e − x ) 2 1 1 e − x − 1 ( 1 e − x ) 2 …

微软发布基于PostgreSQL的开源文档数据库平台DocumentDB

我们很高兴地宣布正式发布DocumentDB——一个开源文档数据库平台,以及基于 vCore、基于 PostgreSQL 构建的 Azure Cosmos DB for MongoDB 的引擎。 过去,NoSQL 数据库提供云专用解决方案,而没有通用的互操作性标准。这导致对可互操作、可移植…

【苍穹外卖 Day1】前后端搭建 Swagger导入接口文档

项目技术选型 前端 直接使用打包好的nginx运行。 后端 1、导入初始代码结构如下: 2、将代码上传远程仓库。 3、创建数据库,并修改数据库配置。 4、断点调试,前后端联调。 5、使用Nginx代理,修改Nginx配置 好处:提…

零基础Vue入门6——Vue router

本节重点: 路由定义路由跳转 前面几节学习的都是单页面的功能(都在专栏里面https://blog.csdn.net/zhanggongzichu/category_12883540.html),涉及到项目研发都是有很多页面的,这里就需要用到路由(vue route…

深度学习里面的而优化函数 Adam,SGD,动量法,AdaGrad 等 | PyTorch 深度学习实战

前一篇文章,使用线性回归模型逼近目标模型 | PyTorch 深度学习实战 本系列文章 GitHub Repo: https://github.com/hailiang-wang/pytorch-get-started 本篇文章内容来自于 强化学习必修课:引领人工智能新时代【梗直哥瞿炜】 深度学习里面的而优化函数 …

mybatis-plus updateById源码

1.版本 : mybatis-plus-core 3.5.1 2.入口:MybatisPlusAutoConfiguration类sqlSessionFactory中的factory.getObject() 3.注入AbstractSqlInjector类中的inspectInject方法中 Overridepublic void inspectInject(MapperBuilderAssistant builderAssistant, Class<?> m…

RabbitMQ 从入门到精通:从工作模式到集群部署实战(三)

文章目录 使用CLI管理RabbitMQrabbitmqctlrabbitmq-queuesrabbitmq-diagnosticsrabbitmq-pluginsrabbitmq-streamsrabbitmq-upgraderabbitmqadmin 使用CLI管理RabbitMQ RabbitMQ CLI 工具需要安装兼容的 Erlang/OTP版本。 这些工具假定系统区域设置为 UTF-8&#xff08;例如en…

PlanLLM: 首个支持开放词汇与封闭集任务的跨模态视频程序规划框架

2025年1月7号&#xff0c;由杨德杰、赵子敬、刘洋联合提出PlanLLM&#xff0c;一种基于可微调大型语言模型&#xff08;LLM&#xff09;的跨模态联合学习框架&#xff0c;用于解决视频程序规划任务。通过引入LLM增强规划模块和互信息最大化模块&#xff0c;PlanLLM突破了现有方…

WGCLOUD监控系统部署教程

官网地址&#xff1a;下载WGCLOUD安装包 - WGCLOUD官网 第一步、环境配置 #安装jdk 1、安装 EPEL 仓库&#xff1a; sudo yum install -y epel-release 2、安装 OpenJDK 11&#xff1a; sudo yum install java-11-openjdk-devel 3、如果成功&#xff0c;你可以通过运行 java …

6-图像金字塔与轮廓检测

文章目录 6.图像金字塔与轮廓检测(1)图像金字塔定义(2)金字塔制作方法(3)轮廓检测方法(4)轮廓特征与近似(5)模板匹配方法6.图像金字塔与轮廓检测 (1)图像金字塔定义 高斯金字塔拉普拉斯金字塔 高斯金字塔:向下采样方法(缩小) 高斯金字塔:向上采样方法(放大)…

DeepSeek-V3 与 DeepSeek R1 对比分析:技术与应用的全面解析

一、背景 在当今科技飞速发展的时代&#xff0c;深度学习技术如同一股强大的浪潮&#xff0c;席卷了自然语言处理&#xff08;NLP&#xff09;、计算机视觉&#xff08;CV&#xff09;以及多模态模型等众多领域。从智能语音助手到图像识别技术&#xff0c;从文本生成工具到多模…

基于 Spring Cloud + Spring AI + VUE 的知识助理平台介绍以及问题

前言&#xff08;一些废话&#xff09; 在看这篇文章的各位大佬&#xff0c;感谢你们留出几分钟时间&#xff0c;来看这个产品介绍&#xff0c;其实重点说实话&#xff0c;不是这个产品怎么样。而是在最后有一个郁结在心里的几个问题&#xff0c;希望大佬们能给出一些建议。万…

IEEE 802.3/802.2 | LLC / SNAP

注&#xff1a;本文为 “IEEE 802.3/802.2 | LLC / SNAP” 相关文章合辑。 未整理去重。 第三篇部分内容出自第二篇。 802.2 协议 haoay321 2010-01-28 20:52:02 LLC 协议 LLC&#xff08;Logic Link Control&#xff0c;逻辑链路控制&#xff09;是 IEEE 802.2 协议中规定…

【Elasticsearch】Geo-distance聚合

geo_distance聚合的形状是圆形。它基于一个中心点&#xff08;origin&#xff09;和一系列距离范围来计算每个文档与中心点的距离&#xff0c;并将文档分配到相应的距离范围内。这种聚合方式本质上是以中心点为圆心&#xff0c;以指定的距离范围为半径的圆形区域来划分数据。 为…

Chapter 4-1. Troubleshooting Congestion in Fibre Channel Fabrics

This chapter covers the following topics: 本章包括以下内容: Congestion troubleshooting methodology and workflow. Hints and tips for troubleshooting congestion. Cisco MDS NX-OS commands for troubleshooting congestion. Case studies demonstrating troubleshoo…

【字节青训营-7】:初探 Kitex 字节微服务框架(使用ETCD进行服务注册与发现)

本文目录 一、Kitex概述二、第一个Kitex应用三、IDL四、服务注册与发现 一、Kitex概述 长话短说&#xff0c;就是字节跳动内部的 Golang 微服务 RPC 框架&#xff0c;具有高性能、强可扩展的特点&#xff0c;在字节内部已广泛使用。 如果对微服务性能有要求&#xff0c;又希望…

设计模式Python版 享元模式

文章目录 前言一、享元模式二、享元模式示例 前言 GOF设计模式分三大类&#xff1a; 创建型模式&#xff1a;关注对象的创建过程&#xff0c;包括单例模式、简单工厂模式、工厂方法模式、抽象工厂模式、原型模式和建造者模式。结构型模式&#xff1a;关注类和对象之间的组合&…

蓝桥杯嵌入式备赛(三)—— LED +按键 + LCD

目录 一、LED1、原理图介绍2、程序代码 二、按键1、原理图介绍2、程序代码 三、LCD1、原理图介绍2、程序代码 一、LED 1、原理图介绍 如果所示&#xff0c;STM32G431RBT6中有八个LED&#xff0c;由八个GPIO控制&#xff0c;分别为PC8-15&#xff0c;当输出为低电平时点亮。其中…