Akka与Java内存模型的关系

简介:

原文链接:http://doc.akka.io/docs/akka/2.3.6/general/jmm.html   译者:clearity

不管你使用的Typesafe系统是Scala版本还是Java版本,都可以使你编写并发程序的过程变得更加容易。这篇文章主要讨论的是Typesafe系统,特别是针对Akka在并发程序中对共享内存的处理部分。

Java内存模型

在之前的Java 5 版本中,Java内存模型的定义是很值得商榷的。以至于在共享内存环境下的多线程处理的结果变得多种多样,比如:

  1. 线程读取不到其他线程写入的值:内存可见性问题
  2. 线程得到了其他线程的“非正常”行为,这也是因为底层指令没有按照期望的顺序执行的结果:指令重排序问题

Java 5版本的JSR 133规范其实已经解决了很多这样的问题。首先Java内存模型是以先序执行原则为前提的规则集合,也就是说它限制的结果是内存的访问必须是依次进行,可是它同时又允许上述的行为乱序的执行。下面是一些规则的例子:

  1. 监控锁规则:在同一把锁的获取之前必须已经进行了锁的释放
  2. Volatile变量规则:对同一个volatile变量的读取必须在对其写入之后

尽管Java内存模型表面上看很复杂,但是在规范的制定上一直在寻求高可用性以及使其具有可编写高性能、扩展性良好的并发程序结构。

角色(Actor)和Java内存模型

针对Akka中的角色(Actor)实现,多线程可以有两种方式来对共享内存进行操作:

  1. 如果消息被发送给一个角色(Actor)。在大多数情况下消息是不可变的,但是也有可能消息并不是如理想中的那样完全不可变化,如果没有先序执行规则的保证,接受消息的角色(Actor)有可能只会看到初始化不完全的数据或者更严重的根本看不到。
  2. 如果角色(Actor)通过消息处理改变了内部状态,然后处理其他的消息时又获取内部状态。在这种情况下你需要注意的是角色(Actor)模型并不能保证同一线程可以对不同的消息用相同的角色(Actor)处理。

为了避免角色(Actor)之间的可见性和重排序问题,Akka提供了下面两个先序执行的原则来保证:

  1. 角色(Actor)发送规则:发送消息给一个角色(Actor)的操作必须在同一个角色(Actor)接受了那条消息之前发生。
  2. 角色(Actor)后续处理规则:同一角色(Actor)的消息处理必须是串行的。

注意:通常意义下也就是当下一消息被角色(Actor)处理的时候,角色(Actor)内部字段的变化在当前是可见的。因此角色(Actor)中的字段不需要被声明为volatile,也不需要是等效的。

上述两个原则只对同一角色(Actor)实例有效,如果使用的是不同的角色(Actor)则没有任何作用。

Future和Java内存模型

注册在Future上的所有回调必须在Future操作完成之后执行。

建议多使用final变量,如果使用了过多的非final变量也必须同时被标识为volatile以便可以在回调中使用字段的最新值。

如果使用过多引用类型,这种情况下必须保证引用指向的实例是线程安全的。我们强烈建议不要使用对象锁,因为它可能造成性能低下,并且最严重的是可能导致死锁的产生。这其实也是使用synchronized的危险所在。

软件事务内存(STM)和Java内存模型

Akka的软件事务内存也支持先序执行规则:

事务引用规则:针对同一事务引用的成功写的提交操作必须发生在同一事务引用的后续读操作之前。

这个规则看起来和Java内存模型中的volatile变量很相似。当前版本的Akka软件事务模型支持延迟写入,因此对于共享内存的实际的写操作只有在事务提交的时候才会执行。事务中的所有写操作都会被置于本地缓冲并对其他事务不可见的,这就保证了不会发生脏读现象。

在Akka中这些规则到底是怎样的这都是实现细节而且都是一直在变动的,具体的下班取决于使用的配置。但是不管怎样他们都是构建在比如监控锁规则或者volatile变量规则这些Java虚拟机模型规则之上的。这就是说,如果你使用Akka,是不用添加同步来保证先序执行的关系的,因为这些Akka已经为你做了。你只需要专注于业务逻辑即可,Akka框架会替你做好这些规则的保证。

角色(Actor)和共享可变状态

但是毕竟Akka是运行在Java虚拟机上的,当然还是要遵守一些规则的。

使用内部角色(Actor)状态并且将它暴露给其他线程


01 class MyActor extends Actor{
02     var state=...
03     def receive ={
04         case _=>
05            //错误
06            //相当的糟糕,共享可变状态
07            //会使你的应用出现奇怪的行为
08            Future { state = NewState }
09            anotherActor ? message onSuccess {r => state = r }
10  
11            //相当糟糕,“sender”会因为每条消息而改变
12            //共享可变状态BUG
13            Future {expensiveCalculation(sender())}
14  
15            //正确
16            //完全安全,“self”可以封装
17            Future {expensiveCalculation() } onComplete { f=> self ! f.value.get }
18  
19            //完全安全,我们封装一个固定值
20            //而且它是一个ActorRef,这个对象是线程安全的
21            val currentSender = sender()
22            Future {expensiveCalculation(currentSender)}
23     }
24 }

消息必须是不可变的,这样可以避开共享可变状态的陷阱。 

目录
相关文章
|
13天前
|
缓存 easyexcel Java
Java EasyExcel 导出报内存溢出如何解决
大家好,我是V哥。使用EasyExcel进行大数据量导出时容易导致内存溢出,特别是在导出百万级别的数据时。以下是V哥整理的解决该问题的一些常见方法,包括分批写入、设置合适的JVM内存、减少数据对象的复杂性、关闭自动列宽设置、使用Stream导出以及选择合适的数据导出工具。此外,还介绍了使用Apache POI的SXSSFWorkbook实现百万级别数据量的导出案例,帮助大家更好地应对大数据导出的挑战。欢迎一起讨论!
108 1
|
1天前
|
存储 缓存 安全
Java内存模型(JMM):深入理解并发编程的基石####
【10月更文挑战第29天】 本文作为一篇技术性文章,旨在深入探讨Java内存模型(JMM)的核心概念、工作原理及其在并发编程中的应用。我们将从JMM的基本定义出发,逐步剖析其如何通过happens-before原则、volatile关键字、synchronized关键字等机制,解决多线程环境下的数据可见性、原子性和有序性问题。不同于常规摘要的简述方式,本摘要将直接概述文章的核心内容,为读者提供一个清晰的学习路径。 ####
13 2
|
2天前
|
存储 Java 编译器
Java内存模型(JMM)深度解析####
本文深入探讨了Java内存模型(JMM)的工作原理,旨在帮助开发者理解多线程环境下并发编程的挑战与解决方案。通过剖析JVM如何管理线程间的数据可见性、原子性和有序性问题,本文将揭示synchronized关键字背后的机制,并介绍volatile关键字和final关键字在保证变量同步与不可变性方面的作用。同时,文章还将讨论现代Java并发工具类如java.util.concurrent包中的核心组件,以及它们如何简化高效并发程序的设计。无论你是初学者还是有经验的开发者,本文都将为你提供宝贵的见解,助你在Java并发编程领域更进一步。 ####
|
2天前
|
存储 安全 Java
什么是 Java 的内存模型?
Java内存模型(Java Memory Model, JMM)是Java虚拟机(JVM)规范的一部分,它定义了一套规则,用于指导Java程序中变量的访问和内存交互方式。
10 1
|
8天前
|
存储 运维 Java
💻Java零基础:深入了解Java内存机制
【10月更文挑战第18天】本文收录于「滚雪球学Java」专栏,专业攻坚指数级提升,希望能够助你一臂之力,帮你早日登顶实现财富自由🚀;同时,欢迎大家关注&&收藏&&订阅!持续更新中,up!up!up!!
21 1
|
11天前
|
存储 算法 Java
Java虚拟机(JVM)的内存管理与性能优化
本文深入探讨了Java虚拟机(JVM)的内存管理机制,包括堆、栈、方法区等关键区域的功能与作用。通过分析垃圾回收算法和调优策略,旨在帮助开发者理解如何有效提升Java应用的性能。文章采用通俗易懂的语言,结合具体实例,使读者能够轻松掌握复杂的内存管理概念,并应用于实际开发中。
|
18天前
|
存储 监控 算法
Java中的内存管理与垃圾回收机制解析
本文深入探讨了Java编程语言中的内存管理方式,特别是垃圾回收机制。我们将了解Java的自动内存管理是如何工作的,它如何帮助开发者避免常见的内存泄漏问题。通过分析不同垃圾回收算法(如标记-清除、复制和标记-整理)以及JVM如何选择合适的垃圾回收策略,本文旨在帮助Java开发者更好地理解和优化应用程序的性能。
|
20天前
|
存储 Java
Java内存模型
【10月更文挑战第11天】Java 内存模型(JMM)是 Java 虚拟机规范中定义的多线程内存访问机制,解决内存可见性、原子性和有序性问题。它定义了主内存和工作内存的概念,以及可见性、原子性和有序性的规则,确保多线程环境下的数据一致性和操作正确性。使用 `synchronized` 和 `volatile` 等同步机制可有效避免数据竞争和不一致问题。
29 3
|
20天前
|
缓存 安全 Java
使用 Java 内存模型解决多线程中的数据竞争问题
【10月更文挑战第11天】在 Java 多线程编程中,数据竞争是一个常见问题。通过使用 `synchronized` 关键字、`volatile` 关键字、原子类、显式锁、避免共享可变数据、合理设计数据结构、遵循线程安全原则和使用线程池等方法,可以有效解决数据竞争问题,确保程序的正确性和稳定性。
32 2
|
11天前
|
监控 安全 Java
Java Z 垃圾收集器如何彻底改变内存管理
大家好,我是V哥。今天聊聊Java的ZGC(Z Garbage Collector)。ZGC是一个低延迟垃圾收集器,专为大内存应用场景设计。其核心优势包括:极低的暂停时间(通常低于10毫秒)、支持TB级内存、使用着色指针实现高效对象管理、并发压缩和去碎片化、不分代的内存管理。适用于实时数据分析、高性能服务器和在线交易系统等场景,能显著提升应用的性能和稳定性。如何启用?只需在JVM启动参数中加入`-XX:+UseZGC`即可。
134 0