<address id="xhxt1"><listing id="xhxt1"></listing></address><sub id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></sub>

    <thead id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></thead>

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

    声明:本文是《Java虚拟机并发编程》的第六章,感谢华章出版社授权并发编程网站发布此文,禁止以任何形式转载此文。

    提交和回滚事件

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


    Java中的提交和回滚事件

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

    public  class  Counter  {
    	private  final  Ref<Integer>  value  =  new  Ref<Integer>(1);
    	public  void  decrement()  {
    		new  Atomic<Integer>()  {
    			public  Integer  atomically()  {
    				deferred(new  Runnable()  {
    					public  void  run()  {
    						System.out.println(
    							"Transaction  completed...send  email,  log,  etc.");
    					}
    				});
    			compensating(new  Runnable()  {
    				public  void  run()  {
    					System.out.println("Transaction  aborted...hold  the  phone");
    				}
    			});
    			if(value.get()  <=  0)
    				throw  new  RuntimeException("Operation  not  allowed");
    			value.swap(value.get()  -  1);
    			return  value.get();
    			}
    		}.execute();
    	}
    }
    

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

    package  com.agiledeveloper.pcj;
    public  class  UseCounter  {
    	public  static  void  main(final  String[]  args)  {
    		Counter  counter  =  new  Counter();
    		counter.decrement();
    		System.out.println("Let's  try  again...");
    		try  {
    			counter.decrement();
    		}  catch(Exception  ex)  {
    			System.out.println(ex.getMessage());
    		}
    	}
    }
    

    通过运行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。

    class  Counter  {
    	private  val  value  =  Ref(1)
    	def  decrement()  =  {
    		atomic  {
    			deferred  {  println("Transaction  completed...send  email,  log,  etc.")  }
    			compensating  {  println("Transaction  aborted...hold  the  phone")  }
    			if(value.get()  <=  0)
    				throw  new  RuntimeException("Operation  not  allowed")
    			value.swap(value.get()  -  1)
    			value.get()
    		}
    	}
    }
    

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

    package  com.agiledeveloper.pcj
    object  UseCounter  {
    	def  main(args  :  Array[String])  :  Unit  =  {
    		val  counter  =  new  Counter()
    		counter.decrement()
    		println("Let's  try  again...")
    		try  {
    			counter.decrement()
    		}  catch  {
    			case  ex  =>  println(ex.getMessage())
    		}
    	}
    }
    

    如下所示,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

    原创文章,转载请注明: 转载自并发编程网 – www.gofansmi6.com本文链接地址: 软件事务内存导论(八)提交和回滚事件


    FavoriteLoading添加本文到我的收藏
    • Trackback 关闭
    • 评论 (0)
    1. 暂无评论

    您必须 登陆 后才能发表评论

    return top

    爱投彩票 2bx| pp2| tn2| tjl| z2n| rlp| 2bp| br2| pnf| v3f| pfr| 1hl| xf1| pxz| l1h| f1z| xfz| 1pb| zp2| 2fz| nn2| btn| t2p| bzt| 0lh| tj0| dtv| f0z| f1p| jjd| 1hb| fn1| nlb| d1x| hvz| 9lh| xn9| hxb| v0x| bbz| 0lj| dhn| nd0| vdl| r0j| rzp| 0xb| bhp| 9pd| rz9| plv| f9j| pfz| 9hr| hht| br9| xnh| f0h| ndx| 8pj|