软件事务内存导论(八)提交和回滚事件

简介:

提交和回滚事件

Java的try-catch-finally语法结构不但使我们可以安全地处理异常,还能够在程序抛出异常时选择性地执行一些代码。同样地,我们也可以控制程序在事务成功提交之后去执行某段代码,而当事务回滚时则去执行另一段代码。StmUtils中的deferred()和compensatiing()这两个函数分别提供了上述功能。特别地,在实现事务的过程中,为保证事务能顺利完成,我们通常会加入一些带副作用的逻辑,而deferred()函数则是一个执行所有这部分逻辑的绝佳地点。


Java中的提交和回滚事件

我们可以把想要在事务成功完成之后执行的代码放在Runnable接口实现部分的代码块中,并将其作为参数传给StmUtils的deferred()函数。同样地,我们也可以把想要在事务失败之后执行的代码封装在Runnable接口中传给compensating()函数。由于这两个函数必须在事务的环境下运行,所以我们只有在automically()函数的函数体中才能调用他们。

01 public  class  Counter  {
02     private  final  Ref<Integer>  value  =  new  Ref<Integer>(1);
03     public  void  decrement()  {
04         new  Atomic<Integer>()  {
05             public  Integer  atomically()  {
06                 deferred(new  Runnable()  {
07                     public  void  run()  {
08                         System.out.println(
09                             "Transaction  completed...send  email,  log,  etc.");
10                     }
11                 });
12             compensating(new  Runnable()  {
13                 public  void  run()  {
14                     System.out.println("Transaction  aborted...hold  the  phone");
15                 }
16             });
17             if(value.get()  <=  0)
18                 throw  new  RuntimeException("Operation  not  allowed");
19             value.swap(value.get()  -  1);
20             return  value.get();
21             }
22         }.execute();
23     }
24 }

在Counter类的定义代码中我们看到,Counter类仅含有一个名为decrement()的实例方法。在这个方法中,我们继承了Atomic类并实现了atomically()函数。在前面的例子中,我们都仅仅是简单地把事务的逻辑代码放在这个位置。而现在,除了原有的逻辑代码之外,我们把事务成功和事务回滚之后要执行的代码也放到了atomically()里面。下面让我们构建一个简单的测试用例来验证一下Counter的功能:


01 package  com.agiledeveloper.pcj;
02 public  class  UseCounter  {
03     public  static  void  main(final  String[]  args)  {
04         Counter  counter  =  new  Counter();
05         counter.decrement();
06         System.out.println("Let's  try  again...");
07         try  {
08             counter.decrement();
09         catch(Exception  ex)  {
10             System.out.println(ex.getMessage());
11         }
12     }
13 }

通过运行UseCounter,我们可以清楚地观察到事务成功完成和失败时程序的执行逻辑:


Transaction  aborted...hold  the  phone
Transaction  completed...send  email,  log,  etc.
Let's  try  again...
Transaction  aborted...hold  the  phone
Operation  not  allowed


当第一次调用decrement()函数并成功完成事务之后,封装在deferred()函数内的代码逻辑将被执行。而当我们第二次调用decrement()时,由于事务执行过程中抛出了异常,所以事务将被回滚,而封装在compensating()函数内的代码也将被执行。最后我们需要注意的是,输出结果中最顶部的那个非预期的重试是由我们之前在6.9节中曾讨论过的默认优化设置所导致的。

deferred()函数是一个执行事务收尾工作以便使其效果固化的绝佳地点,所以我们可以在里面随便进行打印、显示消息、发布通知以及提交数据库事务等操作。如果我们在事务之外有什么遗留的工作待完成,那么这个函数无疑是最好的完成地点。与deferred()类似的是,compensating()函数是记录事务失败信息的好地方。此外,如果我们之前已经将非托管对象(即那些没有使用Akka Ref进行管理的对象)与托管对象混杂在一起的话,那么这里也是纠正这一错误的合适地点——但是由于这种做法太容易出错,所以请你最好避免采用这样的设计思路。

Scala中的提交和回滚事件

在Scala中,我们处理提交和回滚事件的方式与Java基本相同,唯一区别就是在Scala中我们可以将闭包/函数值直接传递给deferred()和compensating()。下面让我们将Counter类由Java转译成Scala。


01 class  Counter  {
02     private  val  value  =  Ref(1)
03     def  decrement()  =  {
04         atomic  {
05             deferred  {  println("Transaction  completed...send  email,  log,  etc.")  }
06             compensating  {  println("Transaction  aborted...hold  the  phone")  }
07             if(value.get()  <=  0)
08                 throw  new  RuntimeException("Operation  not  allowed")
09             value.swap(value.get()  -  1)
10             value.get()
11         }
12     }
13 }

在上面的代码中,我们将事务运行成功时所要执行的那部分代码封装在一个闭包中,然后将其作为参数传递给deferred()函数。类似地,事务回滚时所要执行的代码也被作为一个闭包赋给了compensating()函数。与此同时,这两个函数又与事务逻辑代码一起被置于表示atomic()函数的闭包当中。这段代码再次彰显了Scala在语法上简洁明了的特征。下面让我们将UseConuter类也从Java转译成Scala:


01 package  com.agiledeveloper.pcj
02 object  UseCounter  {
03     def  main(args  :  Array[String])  :  Unit  =  {
04         val  counter  =  new  Counter()
05         counter.decrement()
06         println("Let's  try  again...")
07         try  {
08             counter.decrement()
09         catch  {
10             case  ex  =>  println(ex.getMessage())
11         }
12     }
13 }

如下所示,Scala版代码的执行结果与Java版的结果是完全相同的:


Transaction  aborted...hold  the  phone
Transaction  completed...send  email,  log,  etc.
Let's  try  again...
Transaction  aborted...hold  the  phone
Operation  not  allowed


目录
相关文章
|
6月前
|
存储 Linux 程序员
Linux内存管理宏观篇(二):不同角度去看内存(软件)
Linux内存管理宏观篇(二):不同角度去看内存(软件)
94 0
|
2月前
|
C语言 Android开发 C++
基于MTuner软件进行qt的mingw编译程序的内存泄漏检测
本文介绍了使用MTuner软件进行Qt MinGW编译程序的内存泄漏检测的方法,提供了MTuner的下载链接和测试代码示例,并通过将Debug程序拖入MTuner来定位内存泄漏问题。
基于MTuner软件进行qt的mingw编译程序的内存泄漏检测
|
3月前
|
设计模式 uml
在电脑主机(MainFrame)中只需要按下主机的开机按钮(on()),即可调用其它硬件设备和软件的启动方法,如内存(Memory)的自检(check())、CPU的运行(run())、硬盘(Hard
该博客文章通过一个电脑主机启动的示例代码,展示了外观模式(Facade Pattern)的设计模式,其中主机(MainFrame)类通过调用内部硬件组件(如内存、CPU、硬盘)和操作系统的启动方法来实现开机流程,同时讨论了外观模式的优缺点。
|
4月前
|
Linux 调度
部署02-我们一般接触的是Mos和Wimdows这两款操作系统,很少接触到Linux,操作系统的概述,硬件是由计算机系统中由电子和机械,光电元件所组成的,CPU,内存,硬盘,软件是用户与计算机接口之间
部署02-我们一般接触的是Mos和Wimdows这两款操作系统,很少接触到Linux,操作系统的概述,硬件是由计算机系统中由电子和机械,光电元件所组成的,CPU,内存,硬盘,软件是用户与计算机接口之间
|
5月前
|
监控 Rust 安全
Rust代码在公司电脑监控软件中的内存安全监控
使用 Rust 语言开发的内存安全监控软件在企业中日益重要,尤其对于高安全稳定性的系统。文中展示了如何用 Rust 监控内存使用:通过获取向量长度和内存大小来防止泄漏和溢出。此外,代码示例还演示了利用 reqwest 库自动将监控数据提交至公司网站进行实时分析,以保证系统的稳定和安全。
212 2
|
Rust 监控 并行计算
用Rust构建电脑网络监控软件:内存安全性和多线程编程
在当今数字化世界中,网络安全一直是至关重要的问题。电脑网络监控软件是确保网络系统安全和高效运行的关键工具。然而,编写电脑网络监控软件需要处理复杂的多线程编程和内存安全性问题。Rust编程语言提供了一种强大的方式来构建安全的电脑网络监控软件,同时避免了许多常见的编程错误。
344 0
|
6月前
|
监控 算法 搜索推荐
C++内部监控软件:内存管理与性能调优的完美结合
在当今高度竞争的软件开发领域,内存管理和性能调优是构建高效应用的两个关键方面。本文将介绍一种基于C++的内部监控软件,通过结合精细的内存管理和有效的性能调优,实现了出色的应用性能。我们将深入探讨一些示例代码,演示如何在代码层面实现内存管理和性能优化,最后介绍如何将监控到的数据自动提交到网站。
312 1
|
6月前
|
存储 缓存 安全
从软件和硬件角度去看内存
从软件和硬件角度去看内存
95 0
|
存储 数据库 C语言
Hawkeyes: x86软件迁移Arm的弱内存序问题解决方案
本文介绍了x86软件迁移到Arm过程中可能遇到的弱内存序问题的解决方案,解析了弱内存序问题的根因,介绍了Hawkeyes的架构和实现原理。欢迎有需求的团队发送邮件咨询
1246 0
|
存储 Unix Shell
软件运行机制及内存管理
软件运行机制及内存管理
173 0