com.google.guava/guava/25.1-jre : com/google/common/util/concurrent/RateLimiter.class

RateLimiter
https://github.com/google/guava/guava: Guava is a suite of core and expanded libraries that include utility classes, google's collections, io classes, and much much more.
The Apache Software License, Version 2.0
Kevin Bourrillion (Google)
public abstract class com.google.common.util.concurrent.RateLimiter
  minor version: 0
  major version: 59
  flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
  this_class: com.google.common.util.concurrent.RateLimiter
  super_class: java.lang.Object
{
  private final com.google.common.util.concurrent.RateLimiter$SleepingStopwatch stopwatch;
    descriptor: Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private volatile java.lang.Object mutexDoNotUseDirectly;
    descriptor: Ljava/lang/Object;
    flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
    RuntimeVisibleTypeAnnotations: 
      FIELD
        org.checkerframework.checker.nullness.qual.MonotonicNonNull()

  public static com.google.common.util.concurrent.RateLimiter create(double);
    descriptor: (D)Lcom/google/common/util/concurrent/RateLimiter;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // double permitsPerSecond
         0: .line 127
            dload 0 /* permitsPerSecond */
            invokestatic com.google.common.util.concurrent.RateLimiter$SleepingStopwatch.createFromSystemTimer:()Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
            invokestatic com.google.common.util.concurrent.RateLimiter.create:(DLcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;)Lcom/google/common/util/concurrent/RateLimiter;
            areturn
        end local 0 // double permitsPerSecond
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    1     0  permitsPerSecond  D
    MethodParameters:
                  Name  Flags
      permitsPerSecond  

  static com.google.common.util.concurrent.RateLimiter create(double, com.google.common.util.concurrent.RateLimiter$SleepingStopwatch);
    descriptor: (DLcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;)Lcom/google/common/util/concurrent/RateLimiter;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // double permitsPerSecond
        start local 2 // com.google.common.util.concurrent.RateLimiter$SleepingStopwatch stopwatch
         0: .line 132
            new com.google.common.util.concurrent.SmoothRateLimiter$SmoothBursty
            dup
            aload 2 /* stopwatch */
            dconst_1
            invokespecial com.google.common.util.concurrent.SmoothRateLimiter$SmoothBursty.<init>:(Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;D)V
            astore 3 /* rateLimiter */
        start local 3 // com.google.common.util.concurrent.RateLimiter rateLimiter
         1: .line 133
            aload 3 /* rateLimiter */
            dload 0 /* permitsPerSecond */
            invokevirtual com.google.common.util.concurrent.RateLimiter.setRate:(D)V
         2: .line 134
            aload 3 /* rateLimiter */
            areturn
        end local 3 // com.google.common.util.concurrent.RateLimiter rateLimiter
        end local 2 // com.google.common.util.concurrent.RateLimiter$SleepingStopwatch stopwatch
        end local 0 // double permitsPerSecond
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    3     0  permitsPerSecond  D
            0    3     2         stopwatch  Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
            1    3     3       rateLimiter  Lcom/google/common/util/concurrent/RateLimiter;
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()
    RuntimeInvisibleTypeAnnotations: 
      METHOD_RETURN
        com.google.common.annotations.VisibleForTesting()
    MethodParameters:
                  Name  Flags
      permitsPerSecond  
      stopwatch         

  public static com.google.common.util.concurrent.RateLimiter create(double, long, java.util.concurrent.TimeUnit);
    descriptor: (DJLjava/util/concurrent/TimeUnit;)Lcom/google/common/util/concurrent/RateLimiter;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=8, locals=5, args_size=3
        start local 0 // double permitsPerSecond
        start local 2 // long warmupPeriod
        start local 4 // java.util.concurrent.TimeUnit unit
         0: .line 162
            lload 2 /* warmupPeriod */
            lconst_0
            lcmp
            iflt 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: ldc "warmupPeriod must not be negative: %s"
            lload 2 /* warmupPeriod */
            invokestatic com.google.common.base.Preconditions.checkArgument:(ZLjava/lang/String;J)V
         3: .line 164
            dload 0 /* permitsPerSecond */
            lload 2 /* warmupPeriod */
            aload 4 /* unit */
            ldc 3.0
            invokestatic com.google.common.util.concurrent.RateLimiter$SleepingStopwatch.createFromSystemTimer:()Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
         4: .line 163
            invokestatic com.google.common.util.concurrent.RateLimiter.create:(DJLjava/util/concurrent/TimeUnit;DLcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;)Lcom/google/common/util/concurrent/RateLimiter;
            areturn
        end local 4 // java.util.concurrent.TimeUnit unit
        end local 2 // long warmupPeriod
        end local 0 // double permitsPerSecond
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    5     0  permitsPerSecond  D
            0    5     2      warmupPeriod  J
            0    5     4              unit  Ljava/util/concurrent/TimeUnit;
    MethodParameters:
                  Name  Flags
      permitsPerSecond  
      warmupPeriod      
      unit              

  static com.google.common.util.concurrent.RateLimiter create(double, long, java.util.concurrent.TimeUnit, double, com.google.common.util.concurrent.RateLimiter$SleepingStopwatch);
    descriptor: (DJLjava/util/concurrent/TimeUnit;DLcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;)Lcom/google/common/util/concurrent/RateLimiter;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=8, locals=9, args_size=5
        start local 0 // double permitsPerSecond
        start local 2 // long warmupPeriod
        start local 4 // java.util.concurrent.TimeUnit unit
        start local 5 // double coldFactor
        start local 7 // com.google.common.util.concurrent.RateLimiter$SleepingStopwatch stopwatch
         0: .line 174
            new com.google.common.util.concurrent.SmoothRateLimiter$SmoothWarmingUp
            dup
            aload 7 /* stopwatch */
            lload 2 /* warmupPeriod */
            aload 4 /* unit */
            dload 5 /* coldFactor */
            invokespecial com.google.common.util.concurrent.SmoothRateLimiter$SmoothWarmingUp.<init>:(Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;JLjava/util/concurrent/TimeUnit;D)V
            astore 8 /* rateLimiter */
        start local 8 // com.google.common.util.concurrent.RateLimiter rateLimiter
         1: .line 175
            aload 8 /* rateLimiter */
            dload 0 /* permitsPerSecond */
            invokevirtual com.google.common.util.concurrent.RateLimiter.setRate:(D)V
         2: .line 176
            aload 8 /* rateLimiter */
            areturn
        end local 8 // com.google.common.util.concurrent.RateLimiter rateLimiter
        end local 7 // com.google.common.util.concurrent.RateLimiter$SleepingStopwatch stopwatch
        end local 5 // double coldFactor
        end local 4 // java.util.concurrent.TimeUnit unit
        end local 2 // long warmupPeriod
        end local 0 // double permitsPerSecond
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    3     0  permitsPerSecond  D
            0    3     2      warmupPeriod  J
            0    3     4              unit  Ljava/util/concurrent/TimeUnit;
            0    3     5        coldFactor  D
            0    3     7         stopwatch  Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
            1    3     8       rateLimiter  Lcom/google/common/util/concurrent/RateLimiter;
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()
    RuntimeInvisibleTypeAnnotations: 
      METHOD_RETURN
        com.google.common.annotations.VisibleForTesting()
    MethodParameters:
                  Name  Flags
      permitsPerSecond  
      warmupPeriod      
      unit              
      coldFactor        
      stopwatch         

  private java.lang.Object mutex();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=1
        start local 0 // com.google.common.util.concurrent.RateLimiter this
         0: .line 189
            aload 0 /* this */
            getfield com.google.common.util.concurrent.RateLimiter.mutexDoNotUseDirectly:Ljava/lang/Object;
            astore 1 /* mutex */
        start local 1 // java.lang.Object mutex
         1: .line 190
            aload 1 /* mutex */
            ifnonnull 10
         2: .line 191
            aload 0 /* this */
            dup
            astore 2
            monitorenter
         3: .line 192
            aload 0 /* this */
            getfield com.google.common.util.concurrent.RateLimiter.mutexDoNotUseDirectly:Ljava/lang/Object;
            astore 1 /* mutex */
         4: .line 193
            aload 1 /* mutex */
            ifnonnull 6
         5: .line 194
            aload 0 /* this */
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            dup
            astore 1 /* mutex */
            putfield com.google.common.util.concurrent.RateLimiter.mutexDoNotUseDirectly:Ljava/lang/Object;
         6: .line 191
      StackMap locals: java.lang.Object com.google.common.util.concurrent.RateLimiter
      StackMap stack:
            aload 2
            monitorexit
         7: goto 10
      StackMap locals:
      StackMap stack: java.lang.Throwable
         8: aload 2
            monitorexit
         9: athrow
        10: .line 198
      StackMap locals:
      StackMap stack:
            aload 1 /* mutex */
            areturn
        end local 1 // java.lang.Object mutex
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0   11     0   this  Lcom/google/common/util/concurrent/RateLimiter;
            1   11     1  mutex  Ljava/lang/Object;
      Exception table:
        from    to  target  type
           3     7       8  any
           8     9       8  any

  void <init>(com.google.common.util.concurrent.RateLimiter$SleepingStopwatch);
    descriptor: (Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // com.google.common.util.concurrent.RateLimiter$SleepingStopwatch stopwatch
         0: .line 201
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 202
            aload 0 /* this */
            aload 1 /* stopwatch */
            invokestatic com.google.common.base.Preconditions.checkNotNull:(Ljava/lang/Object;)Ljava/lang/Object;
            checkcast com.google.common.util.concurrent.RateLimiter$SleepingStopwatch
            putfield com.google.common.util.concurrent.RateLimiter.stopwatch:Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
         2: .line 203
            return
        end local 1 // com.google.common.util.concurrent.RateLimiter$SleepingStopwatch stopwatch
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lcom/google/common/util/concurrent/RateLimiter;
            0    3     1  stopwatch  Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
    MethodParameters:
           Name  Flags
      stopwatch  

  public final void setRate(double);
    descriptor: (D)V
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // double permitsPerSecond
         0: .line 225
            dload 1 /* permitsPerSecond */
            dconst_0
            dcmpl
            ifle 1
            dload 1 /* permitsPerSecond */
            invokestatic java.lang.Double.isNaN:(D)Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: ldc "rate must be positive"
         3: .line 224
            invokestatic com.google.common.base.Preconditions.checkArgument:(ZLjava/lang/Object;)V
         4: .line 226
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.RateLimiter.mutex:()Ljava/lang/Object;
            dup
            astore 3
            monitorenter
         5: .line 227
            aload 0 /* this */
            dload 1 /* permitsPerSecond */
            aload 0 /* this */
            getfield com.google.common.util.concurrent.RateLimiter.stopwatch:Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
            invokevirtual com.google.common.util.concurrent.RateLimiter$SleepingStopwatch.readMicros:()J
            invokevirtual com.google.common.util.concurrent.RateLimiter.doSetRate:(DJ)V
         6: .line 226
            aload 3
            monitorexit
         7: goto 10
      StackMap locals: com.google.common.util.concurrent.RateLimiter double java.lang.Object
      StackMap stack: java.lang.Throwable
         8: aload 3
            monitorexit
         9: athrow
        10: .line 229
      StackMap locals:
      StackMap stack:
            return
        end local 1 // double permitsPerSecond
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   11     0              this  Lcom/google/common/util/concurrent/RateLimiter;
            0   11     1  permitsPerSecond  D
      Exception table:
        from    to  target  type
           5     7       8  any
           8     9       8  any
    MethodParameters:
                  Name  Flags
      permitsPerSecond  

  abstract void doSetRate(double, long);
    descriptor: (DJ)V
    flags: (0x0400) ACC_ABSTRACT
    MethodParameters:
                  Name  Flags
      permitsPerSecond  
      nowMicros         

  public final double getRate();
    descriptor: ()D
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // com.google.common.util.concurrent.RateLimiter this
         0: .line 240
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.RateLimiter.mutex:()Ljava/lang/Object;
            dup
            astore 1
            monitorenter
         1: .line 241
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.RateLimiter.doGetRate:()D
            aload 1
            monitorexit
         2: dreturn
         3: .line 240
      StackMap locals: com.google.common.util.concurrent.RateLimiter java.lang.Object
      StackMap stack: java.lang.Throwable
            aload 1
            monitorexit
         4: athrow
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lcom/google/common/util/concurrent/RateLimiter;
      Exception table:
        from    to  target  type
           1     2       3  any
           3     4       3  any

  abstract double doGetRate();
    descriptor: ()D
    flags: (0x0400) ACC_ABSTRACT

  public double acquire();
    descriptor: ()D
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // com.google.common.util.concurrent.RateLimiter this
         0: .line 258
            aload 0 /* this */
            iconst_1
            invokevirtual com.google.common.util.concurrent.RateLimiter.acquire:(I)D
            dreturn
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/google/common/util/concurrent/RateLimiter;
    RuntimeInvisibleAnnotations: 
      com.google.errorprone.annotations.CanIgnoreReturnValue()

  public double acquire(int);
    descriptor: (I)D
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=2
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // int permits
         0: .line 272
            aload 0 /* this */
            iload 1 /* permits */
            invokevirtual com.google.common.util.concurrent.RateLimiter.reserve:(I)J
            lstore 2 /* microsToWait */
        start local 2 // long microsToWait
         1: .line 273
            aload 0 /* this */
            getfield com.google.common.util.concurrent.RateLimiter.stopwatch:Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
            lload 2 /* microsToWait */
            invokevirtual com.google.common.util.concurrent.RateLimiter$SleepingStopwatch.sleepMicrosUninterruptibly:(J)V
         2: .line 274
            dconst_1
            lload 2 /* microsToWait */
            l2d
            dmul
            getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
            lconst_1
            invokevirtual java.util.concurrent.TimeUnit.toMicros:(J)J
            l2d
            ddiv
            dreturn
        end local 2 // long microsToWait
        end local 1 // int permits
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0    3     0          this  Lcom/google/common/util/concurrent/RateLimiter;
            0    3     1       permits  I
            1    3     2  microsToWait  J
    RuntimeInvisibleAnnotations: 
      com.google.errorprone.annotations.CanIgnoreReturnValue()
    MethodParameters:
         Name  Flags
      permits  

  final long reserve(int);
    descriptor: (I)J
    flags: (0x0010) ACC_FINAL
    Code:
      stack=4, locals=3, args_size=2
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // int permits
         0: .line 284
            iload 1 /* permits */
            invokestatic com.google.common.util.concurrent.RateLimiter.checkPermits:(I)V
         1: .line 285
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.RateLimiter.mutex:()Ljava/lang/Object;
            dup
            astore 2
            monitorenter
         2: .line 286
            aload 0 /* this */
            iload 1 /* permits */
            aload 0 /* this */
            getfield com.google.common.util.concurrent.RateLimiter.stopwatch:Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
            invokevirtual com.google.common.util.concurrent.RateLimiter$SleepingStopwatch.readMicros:()J
            invokevirtual com.google.common.util.concurrent.RateLimiter.reserveAndGetWaitLength:(IJ)J
            aload 2
            monitorexit
         3: lreturn
         4: .line 285
      StackMap locals: com.google.common.util.concurrent.RateLimiter int java.lang.Object
      StackMap stack: java.lang.Throwable
            aload 2
            monitorexit
         5: athrow
        end local 1 // int permits
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    6     0     this  Lcom/google/common/util/concurrent/RateLimiter;
            0    6     1  permits  I
      Exception table:
        from    to  target  type
           2     3       4  any
           4     5       4  any
    MethodParameters:
         Name  Flags
      permits  

  public boolean tryAcquire(long, java.util.concurrent.TimeUnit);
    descriptor: (JLjava/util/concurrent/TimeUnit;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // long timeout
        start local 3 // java.util.concurrent.TimeUnit unit
         0: .line 303
            aload 0 /* this */
            iconst_1
            lload 1 /* timeout */
            aload 3 /* unit */
            invokevirtual com.google.common.util.concurrent.RateLimiter.tryAcquire:(IJLjava/util/concurrent/TimeUnit;)Z
            ireturn
        end local 3 // java.util.concurrent.TimeUnit unit
        end local 1 // long timeout
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lcom/google/common/util/concurrent/RateLimiter;
            0    1     1  timeout  J
            0    1     3     unit  Ljava/util/concurrent/TimeUnit;
    MethodParameters:
         Name  Flags
      timeout  
      unit     

  public boolean tryAcquire(int);
    descriptor: (I)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // int permits
         0: .line 317
            aload 0 /* this */
            iload 1 /* permits */
            lconst_0
            getstatic java.util.concurrent.TimeUnit.MICROSECONDS:Ljava/util/concurrent/TimeUnit;
            invokevirtual com.google.common.util.concurrent.RateLimiter.tryAcquire:(IJLjava/util/concurrent/TimeUnit;)Z
            ireturn
        end local 1 // int permits
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    1     0     this  Lcom/google/common/util/concurrent/RateLimiter;
            0    1     1  permits  I
    MethodParameters:
         Name  Flags
      permits  

  public boolean tryAcquire();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=1, args_size=1
        start local 0 // com.google.common.util.concurrent.RateLimiter this
         0: .line 330
            aload 0 /* this */
            iconst_1
            lconst_0
            getstatic java.util.concurrent.TimeUnit.MICROSECONDS:Ljava/util/concurrent/TimeUnit;
            invokevirtual com.google.common.util.concurrent.RateLimiter.tryAcquire:(IJLjava/util/concurrent/TimeUnit;)Z
            ireturn
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/google/common/util/concurrent/RateLimiter;

  public boolean tryAcquire(int, long, java.util.concurrent.TimeUnit);
    descriptor: (IJLjava/util/concurrent/TimeUnit;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=12, args_size=4
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // int permits
        start local 2 // long timeout
        start local 4 // java.util.concurrent.TimeUnit unit
         0: .line 345
            aload 4 /* unit */
            lload 2 /* timeout */
            invokevirtual java.util.concurrent.TimeUnit.toMicros:(J)J
            lconst_0
            invokestatic java.lang.Math.max:(JJ)J
            lstore 5 /* timeoutMicros */
        start local 5 // long timeoutMicros
         1: .line 346
            iload 1 /* permits */
            invokestatic com.google.common.util.concurrent.RateLimiter.checkPermits:(I)V
         2: .line 348
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.RateLimiter.mutex:()Ljava/lang/Object;
            dup
            astore 9
            monitorenter
         3: .line 349
            aload 0 /* this */
            getfield com.google.common.util.concurrent.RateLimiter.stopwatch:Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
            invokevirtual com.google.common.util.concurrent.RateLimiter$SleepingStopwatch.readMicros:()J
            lstore 10 /* nowMicros */
        start local 10 // long nowMicros
         4: .line 350
            aload 0 /* this */
            lload 10 /* nowMicros */
            lload 5 /* timeoutMicros */
            invokevirtual com.google.common.util.concurrent.RateLimiter.canAcquire:(JJ)Z
            ifne 7
         5: .line 351
            aload 9
            monitorexit
         6: iconst_0
            ireturn
         7: .line 353
      StackMap locals: com.google.common.util.concurrent.RateLimiter int long java.util.concurrent.TimeUnit long top top java.lang.Object long
      StackMap stack:
            aload 0 /* this */
            iload 1 /* permits */
            lload 10 /* nowMicros */
            invokevirtual com.google.common.util.concurrent.RateLimiter.reserveAndGetWaitLength:(IJ)J
            lstore 7 /* microsToWait */
        end local 10 // long nowMicros
        start local 7 // long microsToWait
         8: .line 348
            aload 9
            monitorexit
         9: goto 12
        end local 7 // long microsToWait
      StackMap locals: com.google.common.util.concurrent.RateLimiter int long java.util.concurrent.TimeUnit long top top java.lang.Object
      StackMap stack: java.lang.Throwable
        10: aload 9
            monitorexit
        11: athrow
        start local 7 // long microsToWait
        12: .line 356
      StackMap locals: com.google.common.util.concurrent.RateLimiter int long java.util.concurrent.TimeUnit long long
      StackMap stack:
            aload 0 /* this */
            getfield com.google.common.util.concurrent.RateLimiter.stopwatch:Lcom/google/common/util/concurrent/RateLimiter$SleepingStopwatch;
            lload 7 /* microsToWait */
            invokevirtual com.google.common.util.concurrent.RateLimiter$SleepingStopwatch.sleepMicrosUninterruptibly:(J)V
        13: .line 357
            iconst_1
            ireturn
        end local 7 // long microsToWait
        end local 5 // long timeoutMicros
        end local 4 // java.util.concurrent.TimeUnit unit
        end local 2 // long timeout
        end local 1 // int permits
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0   14     0           this  Lcom/google/common/util/concurrent/RateLimiter;
            0   14     1        permits  I
            0   14     2        timeout  J
            0   14     4           unit  Ljava/util/concurrent/TimeUnit;
            1   14     5  timeoutMicros  J
            8   10     7   microsToWait  J
           12   14     7   microsToWait  J
            4    8    10      nowMicros  J
      Exception table:
        from    to  target  type
           3     6      10  any
           7     9      10  any
          10    11      10  any
    MethodParameters:
         Name  Flags
      permits  
      timeout  
      unit     

  private boolean canAcquire(long, long);
    descriptor: (JJ)Z
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=4, locals=5, args_size=3
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // long nowMicros
        start local 3 // long timeoutMicros
         0: .line 361
            aload 0 /* this */
            lload 1 /* nowMicros */
            invokevirtual com.google.common.util.concurrent.RateLimiter.queryEarliestAvailable:(J)J
            lload 3 /* timeoutMicros */
            lsub
            lload 1 /* nowMicros */
            lcmp
            ifgt 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 3 // long timeoutMicros
        end local 1 // long nowMicros
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    2     0           this  Lcom/google/common/util/concurrent/RateLimiter;
            0    2     1      nowMicros  J
            0    2     3  timeoutMicros  J
    MethodParameters:
               Name  Flags
      nowMicros      
      timeoutMicros  

  final long reserveAndGetWaitLength(int, long);
    descriptor: (IJ)J
    flags: (0x0010) ACC_FINAL
    Code:
      stack=4, locals=6, args_size=3
        start local 0 // com.google.common.util.concurrent.RateLimiter this
        start local 1 // int permits
        start local 2 // long nowMicros
         0: .line 370
            aload 0 /* this */
            iload 1 /* permits */
            lload 2 /* nowMicros */
            invokevirtual com.google.common.util.concurrent.RateLimiter.reserveEarliestAvailable:(IJ)J
            lstore 4 /* momentAvailable */
        start local 4 // long momentAvailable
         1: .line 371
            lload 4 /* momentAvailable */
            lload 2 /* nowMicros */
            lsub
            lconst_0
            invokestatic java.lang.Math.max:(JJ)J
            lreturn
        end local 4 // long momentAvailable
        end local 2 // long nowMicros
        end local 1 // int permits
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0    2     0             this  Lcom/google/common/util/concurrent/RateLimiter;
            0    2     1          permits  I
            0    2     2        nowMicros  J
            1    2     4  momentAvailable  J
    MethodParameters:
           Name  Flags
      permits    
      nowMicros  

  abstract long queryEarliestAvailable(long);
    descriptor: (J)J
    flags: (0x0400) ACC_ABSTRACT
    MethodParameters:
           Name  Flags
      nowMicros  

  abstract long reserveEarliestAvailable(int, long);
    descriptor: (IJ)J
    flags: (0x0400) ACC_ABSTRACT
    MethodParameters:
           Name  Flags
      permits    
      nowMicros  

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=1, args_size=1
        start local 0 // com.google.common.util.concurrent.RateLimiter this
         0: .line 393
            getstatic java.util.Locale.ROOT:Ljava/util/Locale;
            ldc "RateLimiter[stableRate=%3.1fqps]"
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* this */
            invokevirtual com.google.common.util.concurrent.RateLimiter.getRate:()D
            invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
            aastore
            invokestatic java.lang.String.format:(Ljava/util/Locale;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            areturn
        end local 0 // com.google.common.util.concurrent.RateLimiter this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lcom/google/common/util/concurrent/RateLimiter;

  private static void checkPermits(int);
    descriptor: (I)V
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // int permits
         0: .line 429
            iload 0 /* permits */
            ifle 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: ldc "Requested permits (%s) must be positive"
            iload 0 /* permits */
            invokestatic com.google.common.base.Preconditions.checkArgument:(ZLjava/lang/String;I)V
         3: .line 430
            return
        end local 0 // int permits
      LocalVariableTable:
        Start  End  Slot     Name  Signature
            0    4     0  permits  I
    MethodParameters:
         Name  Flags
      permits  
}
SourceFile: "RateLimiter.java"
NestMembers:
  com.google.common.util.concurrent.RateLimiter$SleepingStopwatch  com.google.common.util.concurrent.RateLimiter$SleepingStopwatch$1
InnerClasses:
  abstract SleepingStopwatch = com.google.common.util.concurrent.RateLimiter$SleepingStopwatch of com.google.common.util.concurrent.RateLimiter
  final SmoothBursty = com.google.common.util.concurrent.SmoothRateLimiter$SmoothBursty of com.google.common.util.concurrent.SmoothRateLimiter
  final SmoothWarmingUp = com.google.common.util.concurrent.SmoothRateLimiter$SmoothWarmingUp of com.google.common.util.concurrent.SmoothRateLimiter
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.Beta()
      com.google.common.annotations.GwtIncompatible()
/

com.google.guava/ guava/ 25.1-jre/ com/google/common/util/concurrent/RateLimiter.class
