io.projectreactor/reactor-core/3.4.2 : reactor/util/concurrent/SpscLinkedArrayQueue.class

SpscLinkedArrayQueue
https://github.com/reactor/reactor-core: Non-Blocking Reactive Foundation for the JVM (reactor)
Apache License, Version 2.0
Stephane Maldini
David Karnok
Simon Baslé
Sergei Egorov
Sébastien Deleuze
final class reactor.util.concurrent.SpscLinkedArrayQueue<T> extends java.util.AbstractQueue<T> implements java.util.function.BiPredicate<T, T>
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: reactor.util.concurrent.SpscLinkedArrayQueue
  super_class: java.util.AbstractQueue
{
  final int mask;
    descriptor: I
    flags: (0x0010) ACC_FINAL

  volatile long producerIndex;
    descriptor: J
    flags: (0x0040) ACC_VOLATILE

  static final java.util.concurrent.atomic.AtomicLongFieldUpdater<reactor.util.concurrent.SpscLinkedArrayQueue> PRODUCER_INDEX;
    descriptor: Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicLongFieldUpdater<Lreactor/util/concurrent/SpscLinkedArrayQueue;>;

  java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object> producerArray;
    descriptor: Ljava/util/concurrent/atomic/AtomicReferenceArray;
    flags: (0x0000) 
    Signature: Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;

  volatile long consumerIndex;
    descriptor: J
    flags: (0x0040) ACC_VOLATILE

  static final java.util.concurrent.atomic.AtomicLongFieldUpdater<reactor.util.concurrent.SpscLinkedArrayQueue> CONSUMER_INDEX;
    descriptor: Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
    flags: (0x0018) ACC_STATIC, ACC_FINAL
    Signature: Ljava/util/concurrent/atomic/AtomicLongFieldUpdater<Lreactor/util/concurrent/SpscLinkedArrayQueue;>;

  java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object> consumerArray;
    descriptor: Ljava/util/concurrent/atomic/AtomicReferenceArray;
    flags: (0x0000) 
    Signature: Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;

  static final java.lang.Object NEXT;
    descriptor: Ljava/lang/Object;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 51
            ldc Lreactor/util/concurrent/SpscLinkedArrayQueue;
         1: .line 52
            ldc "producerIndex"
         2: .line 51
            invokestatic java.util.concurrent.atomic.AtomicLongFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
         3: .line 50
            putstatic reactor.util.concurrent.SpscLinkedArrayQueue.PRODUCER_INDEX:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
         4: .line 58
            ldc Lreactor/util/concurrent/SpscLinkedArrayQueue;
         5: .line 59
            ldc "consumerIndex"
         6: .line 58
            invokestatic java.util.concurrent.atomic.AtomicLongFieldUpdater.newUpdater:(Ljava/lang/Class;Ljava/lang/String;)Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
         7: .line 57
            putstatic reactor.util.concurrent.SpscLinkedArrayQueue.CONSUMER_INDEX:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
         8: .line 62
            new java.lang.Object
            dup
            invokespecial java.lang.Object.<init>:()V
            putstatic reactor.util.concurrent.SpscLinkedArrayQueue.NEXT:Ljava/lang/Object;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=6, locals=3, args_size=2
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
        start local 1 // int linkSize
         0: .line 64
            aload 0 /* this */
            invokespecial java.util.AbstractQueue.<init>:()V
         1: .line 65
            bipush 8
            iload 1 /* linkSize */
            invokestatic java.lang.Math.max:(II)I
            invokestatic reactor.util.concurrent.Queues.ceilingNextPowerOfTwo:(I)I
            istore 2 /* c */
        start local 2 // int c
         2: .line 66
            aload 0 /* this */
            aload 0 /* this */
            new java.util.concurrent.atomic.AtomicReferenceArray
            dup
            iload 2 /* c */
            iconst_1
            iadd
            invokespecial java.util.concurrent.atomic.AtomicReferenceArray.<init>:(I)V
            dup_x1
            putfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
            putfield reactor.util.concurrent.SpscLinkedArrayQueue.producerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
         3: .line 67
            aload 0 /* this */
            iload 2 /* c */
            iconst_1
            isub
            putfield reactor.util.concurrent.SpscLinkedArrayQueue.mask:I
         4: .line 68
            return
        end local 2 // int c
        end local 1 // int linkSize
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0      this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;
            0    5     1  linkSize  I
            2    5     2         c  I
    MethodParameters:
          Name  Flags
      linkSize  

  public boolean offer();
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=8, args_size=2
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
        start local 1 // java.lang.Object e
         0: .line 72
            aload 1 /* e */
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
            pop
         1: .line 74
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.producerIndex:J
            lstore 2 /* pi */
        start local 2 // long pi
         2: .line 75
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.producerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
            astore 4 /* a */
        start local 4 // java.util.concurrent.atomic.AtomicReferenceArray a
         3: .line 76
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.mask:I
            istore 5 /* m */
        start local 5 // int m
         4: .line 78
            lload 2 /* pi */
            lconst_1
            ladd
            l2i
            iload 5 /* m */
            iand
            istore 6 /* offset */
        start local 6 // int offset
         5: .line 80
            aload 4 /* a */
            iload 6 /* offset */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.get:(I)Ljava/lang/Object;
            ifnull 14
         6: .line 81
            lload 2 /* pi */
            l2i
            iload 5 /* m */
            iand
            istore 6 /* offset */
         7: .line 83
            new java.util.concurrent.atomic.AtomicReferenceArray
            dup
            iload 5 /* m */
            iconst_2
            iadd
            invokespecial java.util.concurrent.atomic.AtomicReferenceArray.<init>:(I)V
            astore 7 /* b */
        start local 7 // java.util.concurrent.atomic.AtomicReferenceArray b
         8: .line 84
            aload 0 /* this */
            aload 7 /* b */
            putfield reactor.util.concurrent.SpscLinkedArrayQueue.producerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
         9: .line 85
            aload 7 /* b */
            iload 6 /* offset */
            aload 1 /* e */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        10: .line 86
            aload 4 /* a */
            iload 5 /* m */
            iconst_1
            iadd
            aload 7 /* b */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        11: .line 87
            aload 4 /* a */
            iload 6 /* offset */
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.NEXT:Ljava/lang/Object;
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        12: .line 88
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.PRODUCER_INDEX:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            lload 2 /* pi */
            lconst_1
            ladd
            invokevirtual java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet:(Ljava/lang/Object;J)V
        end local 7 // java.util.concurrent.atomic.AtomicReferenceArray b
        13: .line 89
            goto 17
        14: .line 91
      StackMap locals: reactor.util.concurrent.SpscLinkedArrayQueue java.lang.Object long java.util.concurrent.atomic.AtomicReferenceArray int int
      StackMap stack:
            lload 2 /* pi */
            l2i
            iload 5 /* m */
            iand
            istore 6 /* offset */
        15: .line 92
            aload 4 /* a */
            iload 6 /* offset */
            aload 1 /* e */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        16: .line 93
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.PRODUCER_INDEX:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            lload 2 /* pi */
            lconst_1
            ladd
            invokevirtual java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet:(Ljava/lang/Object;J)V
        17: .line 96
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 6 // int offset
        end local 5 // int m
        end local 4 // java.util.concurrent.atomic.AtomicReferenceArray a
        end local 2 // long pi
        end local 1 // java.lang.Object e
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   18     0    this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;
            0   18     1       e  TT;
            2   18     2      pi  J
            3   18     4       a  Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;
            4   18     5       m  I
            5   18     6  offset  I
            8   13     7       b  Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;
    Signature: (TT;)Z
    MethodParameters:
      Name  Flags
      e     

  public boolean test(T, );
    descriptor: (Ljava/lang/Object;Ljava/lang/Object;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=9, args_size=3
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
        start local 1 // java.lang.Object first
        start local 2 // java.lang.Object second
         0: .line 110
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.producerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
            astore 3 /* buffer */
        start local 3 // java.util.concurrent.atomic.AtomicReferenceArray buffer
         1: .line 111
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.producerIndex:J
            lstore 4 /* p */
        start local 4 // long p
         2: .line 112
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.mask:I
            istore 6 /* m */
        start local 6 // int m
         3: .line 114
            lload 4 /* p */
            ldc 2
            ladd
            l2i
            iload 6 /* m */
            iand
            istore 7 /* pi */
        start local 7 // int pi
         4: .line 116
            aload 3 /* buffer */
            iload 7 /* pi */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.get:(I)Ljava/lang/Object;
            ifnull 15
         5: .line 118
            new java.util.concurrent.atomic.AtomicReferenceArray
            dup
            iload 6 /* m */
            iconst_2
            iadd
            invokespecial java.util.concurrent.atomic.AtomicReferenceArray.<init>:(I)V
         6: .line 117
            astore 8 /* newBuffer */
        start local 8 // java.util.concurrent.atomic.AtomicReferenceArray newBuffer
         7: .line 119
            aload 0 /* this */
            aload 8 /* newBuffer */
            putfield reactor.util.concurrent.SpscLinkedArrayQueue.producerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
         8: .line 121
            lload 4 /* p */
            l2i
            iload 6 /* m */
            iand
            istore 7 /* pi */
         9: .line 122
            aload 8 /* newBuffer */
            iload 7 /* pi */
            iconst_1
            iadd
            aload 2 /* second */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        10: .line 123
            aload 8 /* newBuffer */
            iload 7 /* pi */
            aload 1 /* first */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        11: .line 124
            aload 3 /* buffer */
            aload 3 /* buffer */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.length:()I
            iconst_1
            isub
            aload 8 /* newBuffer */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        12: .line 126
            aload 3 /* buffer */
            iload 7 /* pi */
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.NEXT:Ljava/lang/Object;
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        13: .line 128
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.PRODUCER_INDEX:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            lload 4 /* p */
            ldc 2
            ladd
            invokevirtual java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet:(Ljava/lang/Object;J)V
        end local 8 // java.util.concurrent.atomic.AtomicReferenceArray newBuffer
        14: .line 130
            goto 19
        15: .line 132
      StackMap locals: reactor.util.concurrent.SpscLinkedArrayQueue java.lang.Object java.lang.Object java.util.concurrent.atomic.AtomicReferenceArray long int int
      StackMap stack:
            lload 4 /* p */
            l2i
            iload 6 /* m */
            iand
            istore 7 /* pi */
        16: .line 133
            aload 3 /* buffer */
            iload 7 /* pi */
            iconst_1
            iadd
            aload 2 /* second */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        17: .line 134
            aload 3 /* buffer */
            iload 7 /* pi */
            aload 1 /* first */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        18: .line 135
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.PRODUCER_INDEX:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            lload 4 /* p */
            ldc 2
            ladd
            invokevirtual java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet:(Ljava/lang/Object;J)V
        19: .line 138
      StackMap locals:
      StackMap stack:
            iconst_1
            ireturn
        end local 7 // int pi
        end local 6 // int m
        end local 4 // long p
        end local 3 // java.util.concurrent.atomic.AtomicReferenceArray buffer
        end local 2 // java.lang.Object second
        end local 1 // java.lang.Object first
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   20     0       this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;
            0   20     1      first  TT;
            0   20     2     second  TT;
            1   20     3     buffer  Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;
            2   20     4          p  J
            3   20     6          m  I
            4   20     7         pi  I
            7   14     8  newBuffer  Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;
    Signature: (TT;TT;)Z
    MethodParameters:
        Name  Flags
      first   
      second  

  public T poll();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=8, args_size=1
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
         0: .line 145
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerIndex:J
            lstore 1 /* ci */
        start local 1 // long ci
         1: .line 146
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
            astore 3 /* a */
        start local 3 // java.util.concurrent.atomic.AtomicReferenceArray a
         2: .line 147
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.mask:I
            istore 4 /* m */
        start local 4 // int m
         3: .line 149
            lload 1 /* ci */
            l2i
            iload 4 /* m */
            iand
            istore 5 /* offset */
        start local 5 // int offset
         4: .line 151
            aload 3 /* a */
            iload 5 /* offset */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.get:(I)Ljava/lang/Object;
            astore 6 /* o */
        start local 6 // java.lang.Object o
         5: .line 153
            aload 6 /* o */
            ifnonnull 7
         6: .line 154
            aconst_null
            areturn
         7: .line 156
      StackMap locals: reactor.util.concurrent.SpscLinkedArrayQueue long java.util.concurrent.atomic.AtomicReferenceArray int int java.lang.Object
      StackMap stack:
            aload 6 /* o */
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.NEXT:Ljava/lang/Object;
            if_acmpne 13
         8: .line 157
            aload 3 /* a */
            iload 4 /* m */
            iconst_1
            iadd
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.get:(I)Ljava/lang/Object;
            checkcast java.util.concurrent.atomic.AtomicReferenceArray
            astore 7 /* b */
        start local 7 // java.util.concurrent.atomic.AtomicReferenceArray b
         9: .line 158
            aload 3 /* a */
            iload 4 /* m */
            iconst_1
            iadd
            aconst_null
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        10: .line 159
            aload 7 /* b */
            iload 5 /* offset */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.get:(I)Ljava/lang/Object;
            astore 6 /* o */
        11: .line 160
            aload 7 /* b */
            astore 3 /* a */
        12: .line 161
            aload 0 /* this */
            aload 7 /* b */
            putfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
        end local 7 // java.util.concurrent.atomic.AtomicReferenceArray b
        13: .line 163
      StackMap locals:
      StackMap stack:
            aload 3 /* a */
            iload 5 /* offset */
            aconst_null
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.lazySet:(ILjava/lang/Object;)V
        14: .line 164
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.CONSUMER_INDEX:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            lload 1 /* ci */
            lconst_1
            ladd
            invokevirtual java.util.concurrent.atomic.AtomicLongFieldUpdater.lazySet:(Ljava/lang/Object;J)V
        15: .line 166
            aload 6 /* o */
            areturn
        end local 6 // java.lang.Object o
        end local 5 // int offset
        end local 4 // int m
        end local 3 // java.util.concurrent.atomic.AtomicReferenceArray a
        end local 1 // long ci
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   16     0    this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;
            1   16     1      ci  J
            2   16     3       a  Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;
            3   16     4       m  I
            4   16     5  offset  I
            5   16     6       o  Ljava/lang/Object;
            9   13     7       b  Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;
    Signature: ()TT;
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public T peek();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=7, args_size=1
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
         0: .line 173
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerIndex:J
            lstore 1 /* ci */
        start local 1 // long ci
         1: .line 174
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerArray:Ljava/util/concurrent/atomic/AtomicReferenceArray;
            astore 3 /* a */
        start local 3 // java.util.concurrent.atomic.AtomicReferenceArray a
         2: .line 175
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.mask:I
            istore 4 /* m */
        start local 4 // int m
         3: .line 177
            lload 1 /* ci */
            l2i
            iload 4 /* m */
            iand
            istore 5 /* offset */
        start local 5 // int offset
         4: .line 179
            aload 3 /* a */
            iload 5 /* offset */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.get:(I)Ljava/lang/Object;
            astore 6 /* o */
        start local 6 // java.lang.Object o
         5: .line 181
            aload 6 /* o */
            ifnonnull 7
         6: .line 182
            aconst_null
            areturn
         7: .line 184
      StackMap locals: reactor.util.concurrent.SpscLinkedArrayQueue long java.util.concurrent.atomic.AtomicReferenceArray int int java.lang.Object
      StackMap stack:
            aload 6 /* o */
            getstatic reactor.util.concurrent.SpscLinkedArrayQueue.NEXT:Ljava/lang/Object;
            if_acmpne 10
         8: .line 185
            aload 3 /* a */
            iload 4 /* m */
            iconst_1
            iadd
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.get:(I)Ljava/lang/Object;
            checkcast java.util.concurrent.atomic.AtomicReferenceArray
            astore 3 /* a */
         9: .line 186
            aload 3 /* a */
            iload 5 /* offset */
            invokevirtual java.util.concurrent.atomic.AtomicReferenceArray.get:(I)Ljava/lang/Object;
            astore 6 /* o */
        10: .line 189
      StackMap locals:
      StackMap stack:
            aload 6 /* o */
            areturn
        end local 6 // java.lang.Object o
        end local 5 // int offset
        end local 4 // int m
        end local 3 // java.util.concurrent.atomic.AtomicReferenceArray a
        end local 1 // long ci
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0   11     0    this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;
            1   11     1      ci  J
            2   11     3       a  Ljava/util/concurrent/atomic/AtomicReferenceArray<Ljava/lang/Object;>;
            3   11     4       m  I
            4   11     5  offset  I
            5   11     6       o  Ljava/lang/Object;
    Signature: ()TT;
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public boolean isEmpty();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
         0: .line 194
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.producerIndex:J
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerIndex:J
            lcmp
            ifne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;

  public int size();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=7, args_size=1
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
         0: .line 199
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerIndex:J
            lstore 1 /* ci */
        start local 1 // long ci
         1: .line 201
      StackMap locals: long
      StackMap stack:
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.producerIndex:J
            lstore 3 /* pi */
        start local 3 // long pi
         2: .line 202
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscLinkedArrayQueue.consumerIndex:J
            lstore 5 /* ci2 */
        start local 5 // long ci2
         3: .line 203
            lload 1 /* ci */
            lload 5 /* ci2 */
            lcmp
            ifne 5
         4: .line 204
            lload 3 /* pi */
            lload 1 /* ci */
            lsub
            l2i
            ireturn
         5: .line 206
      StackMap locals: long long
      StackMap stack:
            lload 5 /* ci2 */
            lstore 1 /* ci */
        end local 5 // long ci2
        end local 3 // long pi
         6: .line 200
            goto 1
        end local 1 // long ci
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    7     0  this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;
            1    7     1    ci  J
            2    6     3    pi  J
            3    6     5   ci2  J

  public void clear();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
         0: .line 212
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual reactor.util.concurrent.SpscLinkedArrayQueue.poll:()Ljava/lang/Object;
            ifnull 1
            aload 0 /* this */
            invokevirtual reactor.util.concurrent.SpscLinkedArrayQueue.isEmpty:()Z
            ifeq 0
         1: .line 214
      StackMap locals:
      StackMap stack:
            return
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;

  public java.util.Iterator<T> iterator();
    descriptor: ()Ljava/util/Iterator;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
         0: .line 218
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 0 // reactor.util.concurrent.SpscLinkedArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscLinkedArrayQueue<TT;>;
    Signature: ()Ljava/util/Iterator<TT;>;
}
Signature: <T:Ljava/lang/Object;>Ljava/util/AbstractQueue<TT;>;Ljava/util/function/BiPredicate<TT;TT;>;
SourceFile: "SpscLinkedArrayQueue.java"
/

io.projectreactor/ reactor-core/ 3.4.2/ reactor/util/concurrent/SpscLinkedArrayQueue.class
