Repository URL to install this package:
|
Version:
0.6.14 ▾
|
Êþº¾ 4 F ² F ³ G ´ F µ F ¶ · ³ ` ¸ ¹ º » ¼ ½ ¾ q ¿ F À F Á Â Ã Ä Å Æ Ç Ã È Ã É Ê F Ë Ì F Í H Î Ï ´ Ð H Ñ F Ò F Ó F Ô ´ F Õ F Ö F × Ø F Ù F Ú F Û F Ü F Ý F Þ ß à á â ã F ä H å q æ ç_ÿÿÿÿÿÿý è é F ê H ë ì í H î ï F ð ì ñ F ò ì ó F ô ì õ ì ö ÷ ø ù Guard InnerClasses fair Z lock *Ljava/util/concurrent/locks/ReentrantLock; activeGuards 1Lcom/google/common/util/concurrent/Monitor$Guard; RuntimeVisibleAnnotations Ljavax/annotation/CheckForNull; RuntimeInvisibleAnnotations 8Lcom/google/errorprone/annotations/concurrent/GuardedBy; value <init> ()V Code LineNumberTable LocalVariableTable this +Lcom/google/common/util/concurrent/Monitor; (Z)V newGuard W(Ljava/util/function/BooleanSupplier;)Lcom/google/common/util/concurrent/Monitor$Guard; isSatisfied $Ljava/util/function/BooleanSupplier; enter (Ljava/time/Duration;)Z time Ljava/time/Duration; #(JLjava/util/concurrent/TimeUnit;)Z interrupt Ljava/lang/InterruptedException; remainingNanos J startTime unit Ljava/util/concurrent/TimeUnit; timeoutNanos interrupted StackMapTable ú enterInterruptibly Exceptions tryEnter ()Z enterWhen 4(Lcom/google/common/util/concurrent/Monitor$Guard;)V guard signalBeforeWaiting satisfied H(Lcom/google/common/util/concurrent/Monitor$Guard;Ljava/time/Duration;)Z T(Lcom/google/common/util/concurrent/Monitor$Guard;JLjava/util/concurrent/TimeUnit;)Z reentrant threw enterWhenUninterruptibly enterIf 4(Lcom/google/common/util/concurrent/Monitor$Guard;)Z enterIfInterruptibly tryEnterIf waitFor waitForUninterruptibly leave isFair isOccupied isOccupiedByCurrentThread getOccupiedDepth ()I getQueueLength hasQueuedThreads hasQueuedThread (Ljava/lang/Thread;)Z thread Ljava/lang/Thread; hasWaiters getWaitQueueLength 4(Lcom/google/common/util/concurrent/Monitor$Guard;)I toSafeNanos #(JLjava/util/concurrent/TimeUnit;)J initNanoTime (J)J (JJ)J signalNextWaiter throwable Ljava/lang/Throwable; signalAllWaiters beginWaitingFor waiters I endWaitingFor p pred await 5(Lcom/google/common/util/concurrent/Monitor$Guard;Z)V awaitUninterruptibly awaitNanos 6(Lcom/google/common/util/concurrent/Monitor$Guard;JZ)Z nanos firstTime access$000 W(Lcom/google/common/util/concurrent/Monitor;)Ljava/util/concurrent/locks/ReentrantLock; x0 SourceFile Monitor.java CLcom/google/common/util/concurrent/ElementTypesAreNonnullByDefault; /Lcom/google/common/annotations/GwtIncompatible; M N V ] V W O P K L (java/util/concurrent/locks/ReentrantLock û ü ý +com/google/common/util/concurrent/Monitor$1 V þ M W ÿ m b f u o u f g W java/lang/InterruptedException i W r f \ &java/lang/IllegalMonitorStateException u ` u ¤ ¥ W v | § ¨ W W ¦ ¥ | | | | | u u java/lang/Long ` W P java/lang/Throwable W W w ¤ W ¡ w ¦ W § )com/google/common/util/concurrent/Monitor java/lang/Object /com/google/common/util/concurrent/Monitor$Guard java/util/concurrent/TimeUnit $com/google/common/base/Preconditions checkNotNull 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; }(Lcom/google/common/util/concurrent/Monitor;Lcom/google/common/util/concurrent/Monitor;Ljava/util/function/BooleanSupplier;)V *com/google/common/util/concurrent/Internal toNanosSaturated (Ljava/time/Duration;)J NANOSECONDS tryLock java/lang/Thread java/lang/System nanoTime ()J currentThread ()Ljava/lang/Thread; lockInterruptibly monitor isHeldByCurrentThread unlock getHoldCount isLocked waiterCount toNanos "com/google/common/primitives/Longs constrainToRange (JJJ)J condition &Ljava/util/concurrent/locks/Condition; $java/util/concurrent/locks/Condition signal next signalAll 1 F G K L M N O P Q R S T Us M 3 V W X 4 *· ± Y ^ _ Z [ \ V ] X _ *· *µ *µ *» Y· µ ± Y g U h i j Z [ \ K L ^ _ X J +¸ W» Y**+· ° Y t u Z [ \ ` a b W X 6 *´ ¶ ± Y Z [ \ b c X @ *+¸ ² ¶ ¬ Y Z [ \ d e b f X g-¸ 7*´ :*´ ¶ ¬¸ 6¸ 77 ² ¶ 6 ¸ ¶ ¬:6¸ 7 §ÿØ: ¸ ¶ ¿ , 8 F # 8 W F Y W Y J # ( , 8¤ =¥ C F H K T¡ W¤ ^¥ d§ Z \ H g h , + i j ( / k j g [ \ g d j g l m ` n j Z M N # D o L p \ ý þ ü ÿ F q ÿ F q >ÿ F q >