码迷,mamicode.com
首页 > 其他好文 > 详细

guava中的SettableFuture分析

时间:2018-02-21 20:27:37      阅读:286      评论:0      收藏:0      [点我收藏+]

标签:tab   关系   运行   同步   处理   并发   guava   合并   run   

当缓存中没有要找的数据时,则要从数据库中去查询,而当并发量比较大时可能会击穿数据库,所以guava cache对同一值的查询做了合并请求的处理。其中就用到了SettableFuture,类似一把锁,只会让一个请求线程去查询数据库而其他查询请求线程(查询同一个值)会处于等待状态。
下面是SettableFuture的UML关系图:

技术分享图片

从图中我们可以看到SettableFuture实现了Future接口,说明可以异步的获取结果。它主要的实现继承于AbstractFuture,而SettableFuture只是做了一层封装。下面主要分析AbstractFuture。
AbstractFuture包含两个属性:一个是内部类Sync对象,一个是ExecutionList对象。
1.ExecutionList
技术分享图片

ExecutionList从字面意思理解就是包含一系列execution的list,看ExecutionList的类图可知,它有一个内部类RunnableExecutorPair表示单向列表list中的一个节点,该节点由Runnable,Executor和next节点构成,当ExecutionList执行execution的时候,先判断executed是否已经执行过,如果没有为了按照顺序执行任务首先会反转单向链表,然后才是executor.execute(runnable)。

2.Sync
技术分享图片

Sync也是继承AQS,实现对线程并发的控制。Sync包含5种状态(运行中:0,完成中:1,已完成:2,已取消:4,已中断:8),存储的值和异常。AbstractFuture类似一把共享锁,某一个时刻只能有一个线程能够拥有AQS的state进行写操作,而读的时候则可以让多个线程同时读。Sync中的set, setException和cancel操作都是写操作。SettableFuture中调用set的过程是这样的:当有一个线程调用set操作或setException时,其他写线程只能进入同步队列中进行等待,而其他读线程会根据Sync当前的状态返回对应的结果。而且AQS的state初始值是0,不管是set,setException和cancel操作后,state的值都不会为再为0,而是各个操作后的状态值。如果同时有多个线程访问,只有一个线程的操作会被接受,其他线程只有等待拥有锁的线程完成该操作,并获取那个操作的结果。

guava中的SettableFuture分析

标签:tab   关系   运行   同步   处理   并发   guava   合并   run   

原文地址:https://www.cnblogs.com/wagne/p/8456782.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!