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

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

这篇关于【并发设计模式】聊聊Immutability模式利用不变性解决并发问题的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/535905

相关文章

SQL Server配置管理器无法打开的四种解决方法

《SQLServer配置管理器无法打开的四种解决方法》本文总结了SQLServer配置管理器无法打开的四种解决方法,文中通过图文示例介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的... 目录方法一:桌面图标进入方法二:运行窗口进入检查版本号对照表php方法三:查找文件路径方法四:检查 S

怎样通过分析GC日志来定位Java进程的内存问题

《怎样通过分析GC日志来定位Java进程的内存问题》:本文主要介绍怎样通过分析GC日志来定位Java进程的内存问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、GC 日志基础配置1. 启用详细 GC 日志2. 不同收集器的日志格式二、关键指标与分析维度1.

Java设计模式---迭代器模式(Iterator)解读

《Java设计模式---迭代器模式(Iterator)解读》:本文主要介绍Java设计模式---迭代器模式(Iterator),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录1、迭代器(Iterator)1.1、结构1.2、常用方法1.3、本质1、解耦集合与遍历逻辑2、统一

Java 线程安全与 volatile与单例模式问题及解决方案

《Java线程安全与volatile与单例模式问题及解决方案》文章主要讲解线程安全问题的五个成因(调度随机、变量修改、非原子操作、内存可见性、指令重排序)及解决方案,强调使用volatile关键字... 目录什么是线程安全线程安全问题的产生与解决方案线程的调度是随机的多个线程对同一个变量进行修改线程的修改操

Redis出现中文乱码的问题及解决

《Redis出现中文乱码的问题及解决》:本文主要介绍Redis出现中文乱码的问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1. 问题的产生2China编程. 问题的解决redihttp://www.chinasem.cns数据进制问题的解决中文乱码问题解决总结

全面解析MySQL索引长度限制问题与解决方案

《全面解析MySQL索引长度限制问题与解决方案》MySQL对索引长度设限是为了保持高效的数据检索性能,这个限制不是MySQL的缺陷,而是数据库设计中的权衡结果,下面我们就来看看如何解决这一问题吧... 目录引言:为什么会有索引键长度问题?一、问题根源深度解析mysql索引长度限制原理实际场景示例二、五大解决

Springboot如何正确使用AOP问题

《Springboot如何正确使用AOP问题》:本文主要介绍Springboot如何正确使用AOP问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录​一、AOP概念二、切点表达式​execution表达式案例三、AOP通知四、springboot中使用AOP导出

Python中Tensorflow无法调用GPU问题的解决方法

《Python中Tensorflow无法调用GPU问题的解决方法》文章详解如何解决TensorFlow在Windows无法识别GPU的问题,需降级至2.10版本,安装匹配CUDA11.2和cuDNN... 当用以下代码查看GPU数量时,gpuspython返回的是一个空列表,说明tensorflow没有找到

解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘问题

《解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘问题》:本文主要介绍解决未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4... 目录未解析的依赖项:‘net.sf.json-lib:json-lib:jar:2.4‘打开pom.XM

XML重复查询一条Sql语句的解决方法

《XML重复查询一条Sql语句的解决方法》文章分析了XML重复查询与日志失效问题,指出因DTO缺少@Data注解导致日志无法格式化、空指针风险及参数穿透,进而引发性能灾难,解决方案为在Controll... 目录一、核心问题:从SQL重复执行到日志失效二、根因剖析:DTO断裂引发的级联故障三、解决方案:修复