zoukankan      html  css  js  c++  java
  • guava中的SettableFuture分析【转】

    转自:https://www.cnblogs.com/wagne/p/8456782.html

    当缓存中没有要找的数据时,则要从数据库中去查询,而当并发量比较大时可能会击穿数据库,所以guava cache对同一值的查询做了合并请求的处理。其中就用到了SettableFuture,类似一把锁,只会让一个请求线程去查询数据库而其他查询请求线程(查询同一个值)会处于等待状态。
    下面是google guava 18.0中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,而是各个操作后的状态值。如果同时有多个线程访问,只有一个线程的操作会被接受,其他线程只有等待拥有锁的线程完成该操作,并获取那个操作的结果。

  • 相关阅读:
    【medium】78. Subsets
    【easy】784. Letter Case Permutation
    【easy】671. Second Minimum Node In a Binary Tree
    【easy】Number of Segments in a String 字符串中的分段数量
    【easy】268. Missing Number
    【easy】235. Lowest Common Ancestor of a Binary Search Tree
    【easy】198. House Robber 123总结……
    【easy】438.Find All Anagrams in a String 找出字符串中所有的变位词
    【easy-】437. Path Sum III 二叉树任意起始区间和
    【easy】437. Path Sum III 二叉树任意起始区间和
  • 原文地址:https://www.cnblogs.com/wangcp-2014/p/13914790.html
Copyright © 2011-2022 走看看