Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
Repository URL to install this package:
|
Version:
0.6.14 ▾
|
Êþº¾ 4 Ü
$
%
$
$
$ & &
$
&
b
b
¡ ¢
$
$ £ ¤
¥ ¦
¥ § & ¨ © ª « ¬
®
¯ ° ± ² ³ LoadingValueReference InnerClasses oldValue ValueReference 3Lcom/google/common/cache/LocalCache$ValueReference; Signature ;Lcom/google/common/cache/LocalCache$ValueReference<TK;TV;>; futureValue 2Lcom/google/common/util/concurrent/SettableFuture; 7Lcom/google/common/util/concurrent/SettableFuture<TV;>; stopwatch "Lcom/google/common/base/Stopwatch; <init> ()V Code LineNumberTable LocalVariableTable this :Lcom/google/common/cache/LocalCache$LoadingValueReference; LocalVariableTypeTable BLcom/google/common/cache/LocalCache$LoadingValueReference<TK;TV;>; 6(Lcom/google/common/cache/LocalCache$ValueReference;)V
StackMapTable >(Lcom/google/common/cache/LocalCache$ValueReference<TK;TV;>;)V isLoading ()Z isActive getWeight ()I set (Ljava/lang/Object;)Z newValue Ljava/lang/Object; TV; (TV;)Z RuntimeVisibleTypeAnnotations 5Lorg/checkerframework/checker/nullness/qual/Nullable; setException (Ljava/lang/Throwable;)Z t Ljava/lang/Throwable; fullyFailedFuture K(Ljava/lang/Throwable;)Lcom/google/common/util/concurrent/ListenableFuture; P(Ljava/lang/Throwable;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>; notifyNewValue (Ljava/lang/Object;)V (TV;)V
loadFuture m(Ljava/lang/Object;Lcom/google/common/cache/CacheLoader;)Lcom/google/common/util/concurrent/ListenableFuture;
previousValue 4Lcom/google/common/util/concurrent/ListenableFuture; result key loader %Lcom/google/common/cache/CacheLoader; 9Lcom/google/common/util/concurrent/ListenableFuture<TV;>; TK; .Lcom/google/common/cache/CacheLoader<-TK;TV;>; ´ µ l(TK;Lcom/google/common/cache/CacheLoader<-TK;TV;>;)Lcom/google/common/util/concurrent/ListenableFuture<TV;>; compute E(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object; e )Ljava/util/concurrent/ExecutionException; th function Ljava/util/function/BiFunction; -Ljava/util/function/BiFunction<-TK;-TV;+TV;>; 5(TK;Ljava/util/function/BiFunction<-TK;-TV;+TV;>;)TV; elapsedNanos ()J waitForValue ()Ljava/lang/Object;
Exceptions ()TV; get getOldValue 5()Lcom/google/common/cache/LocalCache$ValueReference; =()Lcom/google/common/cache/LocalCache$ValueReference<TK;TV;>; getEntry *()Lcom/google/common/cache/ReferenceEntry; 2()Lcom/google/common/cache/ReferenceEntry<TK;TV;>; copyFor (Ljava/lang/ref/ReferenceQueue;Ljava/lang/Object;Lcom/google/common/cache/ReferenceEntry;)Lcom/google/common/cache/LocalCache$ValueReference; queue Ljava/lang/ref/ReferenceQueue; value entry (Lcom/google/common/cache/ReferenceEntry; #Ljava/lang/ref/ReferenceQueue<TV;>; 0Lcom/google/common/cache/ReferenceEntry<TK;TV;>; (Ljava/lang/ref/ReferenceQueue<TV;>;TV;Lcom/google/common/cache/ReferenceEntry<TK;TV;>;)Lcom/google/common/cache/LocalCache$ValueReference<TK;TV;>; w<K:Ljava/lang/Object;V:Ljava/lang/Object;>Ljava/lang/Object;Lcom/google/common/cache/LocalCache$ValueReference<TK;TV;>;
SourceFile LocalCache.java 3 < 3 4 ¶ · ¸ . / ¹ º » 1 2 ¼ ½ u ) + A @ B C D E L M ¾ ¿ Q À » s p Á Â Ã Ä Å Æ :com/google/common/cache/LocalCache$LoadingValueReference$1 3 Ç È É Ê Ë Ì java/lang/Throwable P Q java/lang/InterruptedException Í Î Ï Ð 4 o p 'java/util/concurrent/ExecutionException Ñ Ò Ó Ô Õ Ö × Ø Ù Ú Û 8com/google/common/cache/LocalCache$LoadingValueReference java/lang/Object 1com/google/common/cache/LocalCache$ValueReference 2com/google/common/util/concurrent/ListenableFuture #com/google/common/cache/CacheLoader 0com/google/common/util/concurrent/SettableFuture create 4()Lcom/google/common/util/concurrent/SettableFuture; com/google/common/base/Stopwatch createUnstarted $()Lcom/google/common/base/Stopwatch; "com/google/common/cache/LocalCache unset )com/google/common/util/concurrent/Futures immediateFailedFuture start load &(Ljava/lang/Object;)Ljava/lang/Object; immediateFuture H(Ljava/lang/Object;)Lcom/google/common/util/concurrent/ListenableFuture; reload Z(Ljava/lang/Object;Ljava/lang/Object;)Lcom/google/common/util/concurrent/ListenableFuture; =(Lcom/google/common/cache/LocalCache$LoadingValueReference;)V /com/google/common/util/concurrent/MoreExecutors directExecutor !()Ljava/util/concurrent/Executor; transform ª(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/base/Function;Ljava/util/concurrent/Executor;)Lcom/google/common/util/concurrent/ListenableFuture; java/lang/Thread
currentThread ()Ljava/lang/Thread; interrupt java/util/function/BiFunction apply 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; java/util/concurrent/TimeUnit NANOSECONDS Ljava/util/concurrent/TimeUnit; elapsed "(Ljava/util/concurrent/TimeUnit;)J 2com/google/common/util/concurrent/Uninterruptibles getUninterruptibly 1(Ljava/util/concurrent/Future;)Ljava/lang/Object; $ % & @ ) + , - . / , 0 1 2 3 4 5 F *· ± 6
7 8 9 : 8 ; 3 < 5 "*· *¸ µ *¸ µ *+Ç ¸ § +µ ± 6
!
7 " 8 9 " ) + : " 8 ; " ) - = % ÿ $ & $ÿ $ & $ & , > ? @ 5 > ¬ 6
¡ 7 8 9 : 8 ; A @ 5 F
*´ ¹ ¬ 6
¦ 7
8 9 :
8 ; B C 5 F
*´ ¹
¬ 6
« 7
8 9 :
8 ; D E 5 Y *´ +¶ ¬ 6
¯ 7 8 9 F G : 8 ; F H , I J K L M 5 O *´ +¶ ¬ 6
³ 7 8 9 N O : 8 ; P Q 5 K +¸
° 6
· 7 8 9 N O : 8 ; , R S T 5 { +Æ *+¶ W§
*¸ µ ± 6
¼
¿
Â
Æ 7 8 9 F G : 8 ; F H =
, U J K V W 5 Ð }*´ ¶ W*´ ¹ N-Ç ,+¶ :*¶
*´ § ¸ °,+-¶ :Ç ¸ °» Y*· ¸ ¸ °N*-¶
*´ § *-· :-Á ¸ ¶ ° 2 V 3 D V E U V 6 B
Ê
Ë
Ì
Í
Î 3
Ð ;
Ñ @
Ò E
Ö O
ß R
Ö V
à W
á m
â t
ã z
å 7 R F G D X G ; F Y m Z Y W & N O } 8 9 } [ G } \ ] : H F H D X H ; F ^ m Z ^ } 8 ; } [ _ } \ ` = ; ý - % %D aú ü aÿ $ % b ü D aü a , c d e 5 \ <*´ ¶ W*´ ¹ N§ :N,+-¹ :§ :*¶ W¿*¶ W° # & 6 2
ê
í
ð
î
ï
ó #
÷ &
ô (
õ /
ö 2
ø 9
ù 7 \ X G f g # F G (
h O < 8 9 < [ G < i j # X G 2
F G : H X H # F H < 8 ; < [ _ < i k # X H 2
F H = U ü %L ü % , l J
K m n 5 G *´ ² !¶ " 6
ý 7 8 9 : 8 ; o p 5 D *´ ¸ #° 6 7 8 9 : 8 ; q , r s p 5 F
*´ ¹ ° 6 7
8 9 :
8 ; , r t u 5 A *´ ° 6 7 8 9 : 8 ; , v w x 5 > ° 6 7 8 9 : 8 ; , y z { 5 z *° 6 7 * 8 9 | } ~ G : * 8 ; | ~ H , J K ,
( $ ' & *