【并发设计模式】聊聊Immutability模式利用不变性解决并发问题

上一篇文章,我们介绍了如何利用二阶段停止协议进行优雅停止线程和线程池,本篇介绍在并发编程中数据安全性,我们知道针对于数据的操作,读和写(添加、删除、修改), 在并发线程读写的时候,变量不加锁的情况下,一定会有线程安全问题。但是如果变量只有读操作,多个线程就不存在资源的竞争操作,因为变量 i = 10, 多个线程不修改,都读取到的一定是10。

所以Immutability模式就是利用变量只读的方式。对象一创建之后,就不会在修改。

实现不可变性的类

如何实现呢,其实很简单,就是针对的类和属性 添加final 关键词进行修饰。并且只提供只读的方法。

Java中String、Integer 、Double等基础类都是具备不可变性。类和属性都是final,所有方法都是只读的。但是你可能使用过String的替换方法,我们看看源码看是怎么回事。

类和属性都被final修饰。replace 其实是通过内部构件了一个新的char数组。进行操作的。 也就是创建了一个新的不可变对象。

public final class String {private final char value[];// 字符替换String replace(char oldChar, char newChar) {// 无需替换,直接返回 this  if (oldChar == newChar){return this;}int len = value.length;int i = -1;/* avoid getfield opcode */char[] val = value; // 定位到需要替换的字符位置while (++i < len) {if (val[i] == oldChar) {break;}}// 未找到 oldChar,无需替换if (i >= len) {return this;} // 创建一个 buf[],这是关键// 用来保存替换后的字符串char buf[] = new char[len];for (int j = 0; j < i; j++) {buf[j] = val[j];}while (i < len) {char c = val[i];buf[i] = (c == oldChar) ? newChar : c;i++;}// 创建一个新的字符串返回// 原字符串不会发生任何变化return new String(buf, true);}
}

问题: 那么如果频繁创建过多相同的对象,会不会对内存造成影响。又如何解决呢??

享元模式避免重复创建对象

这里可能要留一个坑了,那就是什么是享元模式,后边有时间花一篇文章在介绍。
简单一点其实享元模式就是可以共享的单元,目的是达到对象的服用、共享,前提是不可变对象。
将相同的对象只保存一份,可以复用。实现比较简单,就是使用list或者map存储共享的对象。
这里简单说下和单例模式的区别:单例模式是为了保证对象的全局唯一性,享元模式是达到对象的服用。

享元模式工作模式:享元模式其实就是一个对象池,创建的时候,先看池里有没有,没有的话新创建,有的话 直接复用。

我们通过分析Long 可以发现,通过一个静态类 提前创建-128到127之间的数。使用的时候,先查看是否在这个范围,在的话直接使用。Integer类也是大同小异。

    //缓存-128到127之间的数值private static class LongCache {private LongCache(){}static final Long cache[] = new Long[-(-128) + 127 + 1];static {for(int i = 0; i < cache.length; i++)cache[i] = new Long(i - 128);}}public static Long valueOf(long l) {final int offset = 128;// 缓存内的数据直接使用if (l >= -128 && l <= 127) { // will cachereturn LongCache.cache[(int)l + offset];}return new Long(l);}

问题:那么可以使用基础类做一把锁嘛?

private Integer lockA = new Integer(0);private Integer lockB = new Integer(0);public static void main(String[] args) throws InterruptedException {TestBaseLock t = new TestBaseLock();new Thread(()-> { t.lockA();}).start();new Thread(()-> { t.lockB();}).start();TimeUnit.SECONDS.sleep(100);}public void lockA () {synchronized (lockA) {System.out.println("LockA before");try {TimeUnit.SECONDS.sleep(10);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("LockA after");}}public void lockB ()  {synchronized (lockB) {System.out.println("LockB before");try {TimeUnit.SECONDS.sleep(10);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("LockB after");}}

从执行结果来看的话,发现啊,怎么会lockA 获取锁的同时,lockB也可以获取呢。因为本质就是Integer lockA 和 lockB 共享的是同一个对象。公用一把锁。并不是两把锁。

LockA before
LockB before
LockA after
LockB after

注意点

在实际的编程中,可能A对象内部的对象属性B 和 属性值是C是不可变的,但是对象属性B 可以被修改。 所以我们需要合理评估不可变性的边界在哪里,是否属性对象也需要保证。
如果需要保证就需要加上voliatie保证可见性、如果保证原子性,可以使用原子类进行构建。

class B{int age=0;int name="abc";
}
final class A {final B b;final Integer c;void setAge(int a){c=a;}
}

总结

好了,本篇主要介绍了Immutability模式,利用享元模式解决不可变性的重复对象的问题,在多线程编程的时候,我们需要首先考虑是否数据是否不可变,如果不可变,就简单了,如果不行在使用别的设计模式来解决数据安全问题。
在分布式系统中,有无状态服务,就是不存储数据,这种方式可以很好的无限水平拓展,当然也就是有对象的无状态对象,类似于函数式编程,我们只需要输入输出,不改变数据。

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

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

相关文章

redis哨兵+redis主从复制(在虚拟机centos的docker下)

1.安装docker Docker安装(CentOS)简单使用-CSDN博客 2.redis主从复制 redis主从复制(在虚拟机centos的docker下)-CSDN博客 3.编辑3个redis配置 cd /etc mkdir redis-sentinel cd redis-sentinel/ wget http://download.redis.io/redis-stable/sentinel.confcp sentinel.co…

ssh 免密登陆公钥设置失败分析调试

前景 看到这里肯定已经知道如何设置免密登陆。本文主要用于解决免密登陆设置失效问题。 ssh调试 目的 ssh设置了公钥仍然无法免密登陆; 需要调试 解决 通过systemctl status sshd的日志输出查看原因 步骤 打开调试 systemctl status sshd查看所在服务文件 $ sudo sys…

【并发编程篇】读锁readLock()和写锁writeLock()

文章目录 &#x1f6f8;情景引入⭐解决问题 readLock()和writeLock()都是ReadWriteLock接口中定义的方法&#xff0c;用于获取读锁和写锁。 readLock()方法返回一个读锁&#xff0c;允许多个线程同时获取该锁&#xff0c;以进行并发读取操作。如果当前已有一个写锁或其他线程正…

GIT具体配置步骤详解

GIT配置具体步骤如下 SDK 使用 Repo 工具管理&#xff0c;拉取 SDK 需要配置安装 Repo 工具。 Repo is a tool built on top of Git. Repo helps manage many Git repositories, does the uploads to revision control systems, and automates parts of the development workf…

装饰器模式和责任链模式区别

近期看了 mybatis 的源码&#xff0c;发现二级缓存这块用了装饰器模式将各个功能的缓存进行嵌套&#xff0c;源码上也是讲到使用了装饰器模式&#xff0c;但是看着跟责任链模式类似&#xff0c;本着搞清楚的想法&#xff0c;搜了很多资料&#xff0c;看了书籍《Head First 设计…

AI行业新趋势:百模大战中的变革与未来

AI行业新趋势&#xff1a;百模大战中的变革与未来 人工智能&#xff0c;这个曾经被视为科幻小说的情节&#xff0c;如今已经成为我们生活中的常态。从智能手机、自动驾驶汽车&#xff0c;到智能家居、医疗诊断&#xff0c;AI的应用已经深入到我们生活的各个角落。然而&#xf…

多维时序 | MATLAB实CNN-BiGRU-Mutilhead-Attention卷积网络结合双向门控循环单元网络融合多头注意力机制多变量时间序列预测

多维时序 | MATLAB实现CNN-BiGRU-Mutilhead-Attention卷积网络结合双向门控循环单元网络融合多头注意力机制多变量时间序列预测 目录 多维时序 | MATLAB实现CNN-BiGRU-Mutilhead-Attention卷积网络结合双向门控循环单元网络融合多头注意力机制多变量时间序列预测预测效果基本介…

ubuntu 22.04 安装mysql服务

完整内容&#xff1a; https://developer.aliyun.com/article/1260321 # 安装服务 sudo apt install mysql-server# 按向导设置root密码 sudo mysql_secure_installation# 使用设置的密码登录 sudo mysql -u root -p也可以使用工具登录&#xff0c;例如: navicat for mysql

协同工作php,PHPOA:灵活、高效、协同,让企业高效运转

原标题&#xff1a;PHPOA&#xff1a;灵活、高效、协同&#xff0c;让企业高效运转PHPOA系统作为一个管理系统&#xff0c;它的职责就是为企业高效运转而服务&#xff0c;以提高企业的办公效率为己任&#xff0c;减少不必要的资源浪费为责任。它保持高度的灵活性、高效性与协同…

ubuntu搭建php开发环境记录

2019独角兽企业重金招聘Python工程师标准>>> 这两天自己在阿里云上面买了一个ecs&#xff0c;系统选的是ubuntu16.04&#xff0c;第一件事就是先搭环境&#xff0c;这次准备使用lamp组合。 Apache安装 首先安装apache服务器&#xff0c;ubuntu下面使用apt-get来下载…

php datediff 函数,dateAdd与DateDiff函数的js代码

1、DateAdd函数&#xff1a;复制代码 代码示例:function DateAdd(interval,number,date){switch(interval.toLowerCase()){case "y": return new Date(date.setFullYear(date.getFullYear()number));case "m": return new Date(date.setMonth(date.getMont…

mysql索引为啥要选择B+树 (下)

有读者在 mysql索引为啥要选择B树 (上) 上篇文章中留言总结了选择 B 树的原因&#xff0c;大体上说对了&#xff0c;今天我们再一起来看看具体的原因。 索引为什么要保存在硬盘中首先要明白几个概念&#xff0c;服务器存储一般分内存和硬盘&#xff0c;内存的大小相对于硬盘来说…

des加解密java c#,C#编写DES加密、解密类

这个C#类封装的DES加密解密&#xff0c;可以使用默认秘钥进行加密、解密&#xff0c;也可以自定义秘钥进行加密、解密&#xff0c;调用简单方便。示例一&#xff1a;using System;using System.Security.Cryptography;using System.Text;namespace DotNet.Utilities{/// /// DE…

八年开发程序员浅析SpringBoot 之 Shiro 与 Redis 多级缓存问题

前言 来自不愿意透露姓名的小师弟的投稿。这篇主要讲了&#xff0c;项目中配置了多缓存遇到的坑&#xff0c;以及解决办法。 发现问题 在一次项目实践中有实现多级缓存其中有已经包括了 Shiro 的 Cache &#xff0c;本以为开启 redis 的缓存是一件很简单的事情只需要在启动类上…

Web端H.265播放器研发解密

音视频编解码对于前端工程师是一个比较少涉足的领域&#xff0c;涉及到流媒体技术中的文本、图形、图像、音频和视频多种理论知识的学习&#xff0c;才能够应用到具体实践中&#xff0c;本团队在多媒体领域深耕两年多&#xff0c;才算是有一定产出&#xff0c;我们自研web播放器…

拳击 武术java父类,拳击是一种很有力量的武术类型

原标题&#xff1a;拳击是一种很有力量的武术类型拳击是一种很有力量的武术类型&#xff0c;拳击比赛策略有很多&#xff0c;围绳技术是其中之一。那么拳击比赛策略技巧有哪些呢&#xff1f;下面养生之道网为您解析拳击比赛策略技巧有哪些&#xff0c;看看吧。1、当拳手靠在围绳…

捧上天的AI落地困难,“ 不懂变通”的华为云如何应付?

前几年&#xff0c;AI几乎被捧上天&#xff0c;各大公司倾巢出动&#xff0c;推出了不少吸眼球的应用和产品。如今&#xff0c;这些AI成果是否真得让企业从中获得价值&#xff1f;绕不开的数据、隐私和安全问题作何解&#xff1f;不同领域、不同规模、不同技术能力的企业如何最…

Apache-Flink深度解析-DataStream-Connectors之Kafka

Kafka 简介Apache Kafka是一个分布式发布-订阅消息传递系统。 它最初由LinkedIn公司开发&#xff0c;LinkedIn于2010年贡献给了Apache基金会并成为顶级开源项目。Kafka用于构建实时数据管道和流式应用程序。它具有水平扩展性、容错性、极快的速度&#xff0c;目前也得到了广泛的…

Java使用继承的语法是,Java基础语法八 继承

1、超类和子类超类和子类父类与子类多态&#xff1a;一个对象变量可以指示多种实际类型的现象称为多态一个变量可以引用父类对象&#xff0c;也可以引用其子类对象&#xff0c;这就是多态。不能将一个超类的引用赋给子类变量&#xff0c;因为调用子类方法时可能发生运行错误子类…

kaka 1.0.0 重磅发布,服务于后端的事件领域模型框架。

百度智能云 云生态狂欢季 热门云产品1折起>>> kaka 1.0.0正式发布了&#xff0c;从三个月前的kaka-notice-lib 1.0.0的发布&#xff0c;经过多次研磨&#xff0c;终于迎来了本次重大更新。 kaka是一款服务于java后端的事件领域模型框架&#xff0c;主要目的为解耦业…