final class reactor.util.concurrent.SpscArrayQueue<T> extends reactor.util.concurrent.SpscArrayQueueP3<T> implements java.util.Queue<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: reactor.util.concurrent.SpscArrayQueue
  super_class: reactor.util.concurrent.SpscArrayQueueP3
{
  private static final long serialVersionUID;
    descriptor: J
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    ConstantValue: 494623116936946976

  void <init>(int);
    descriptor: (I)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // int capacity
         0: .line 45
            aload 0 /* this */
            iload 1 /* capacity */
            invokestatic reactor.util.concurrent.Queues.ceilingNextPowerOfTwo:(I)I
            invokespecial reactor.util.concurrent.SpscArrayQueueP3.<init>:(I)V
         1: .line 46
            return
        end local 1 // int capacity
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    2     1  capacity  I
    MethodParameters:
          Name  Flags
      capacity  

  public boolean offer();
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.lang.Object e
         0: .line 50
            aload 1 /* e */
            ldc "e"
            invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
            pop
         1: .line 51
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscArrayQueue.producerIndex:J
            lstore 2 /* pi */
        start local 2 // long pi
         2: .line 52
            lload 2 /* pi */
            l2i
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscArrayQueue.mask:I
            iand
            istore 4 /* offset */
        start local 4 // int offset
         3: .line 53
            aload 0 /* this */
            iload 4 /* offset */
            invokevirtual reactor.util.concurrent.SpscArrayQueue.get:(I)Ljava/lang/Object;
            ifnull 5
         4: .line 54
            iconst_0
            ireturn
         5: .line 56
      StackMap locals: long int
      StackMap stack:
            aload 0 /* this */
            iload 4 /* offset */
            aload 1 /* e */
            invokevirtual reactor.util.concurrent.SpscArrayQueue.lazySet:(ILjava/lang/Object;)V
         6: .line 57
            getstatic reactor.util.concurrent.SpscArrayQueue.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
         7: .line 58
            iconst_1
            ireturn
        end local 4 // int offset
        end local 2 // long pi
        end local 1 // java.lang.Object e
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    8     0    this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    8     1       e  TT;
            2    8     2      pi  J
            3    8     4  offset  I
    Signature: (TT;)Z
    MethodParameters:
      Name  Flags
      e     

  public T poll();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=1
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
         0: .line 64
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscArrayQueue.consumerIndex:J
            lstore 1 /* ci */
        start local 1 // long ci
         1: .line 65
            lload 1 /* ci */
            l2i
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscArrayQueue.mask:I
            iand
            istore 3 /* offset */
        start local 3 // int offset
         2: .line 67
            aload 0 /* this */
            iload 3 /* offset */
            invokevirtual reactor.util.concurrent.SpscArrayQueue.get:(I)Ljava/lang/Object;
            astore 4 /* v */
        start local 4 // java.lang.Object v
         3: .line 68
            aload 4 /* v */
            ifnull 6
         4: .line 69
            aload 0 /* this */
            iload 3 /* offset */
            aconst_null
            invokevirtual reactor.util.concurrent.SpscArrayQueue.lazySet:(ILjava/lang/Object;)V
         5: .line 70
            getstatic reactor.util.concurrent.SpscArrayQueue.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
         6: .line 72
      StackMap locals: long int java.lang.Object
      StackMap stack:
            aload 4 /* v */
            areturn
        end local 4 // java.lang.Object v
        end local 3 // int offset
        end local 1 // long ci
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    7     0    this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            1    7     1      ci  J
            2    7     3  offset  I
            3    7     4       v  TT;
    Signature: ()TT;
    RuntimeVisibleAnnotations: 
      reactor.util.annotation.Nullable()

  public T peek();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
         0: .line 78
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscArrayQueue.consumerIndex:J
            l2i
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscArrayQueue.mask:I
            iand
            istore 1 /* offset */
        start local 1 // int offset
         1: .line 79
            aload 0 /* this */
            iload 1 /* offset */
            invokevirtual reactor.util.concurrent.SpscArrayQueue.get:(I)Ljava/lang/Object;
            areturn
        end local 1 // int offset
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            1    2     1  offset  I
    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.SpscArrayQueue this
         0: .line 84
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscArrayQueue.producerIndex:J
            aload 0 /* this */
            getfield reactor.util.concurrent.SpscArrayQueue.consumerIndex:J
            lcmp
            ifne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;

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

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

  public boolean contains(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.lang.Object o
         0: .line 107
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 1 // java.lang.Object o
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    1     1     o  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      o     

  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.SpscArrayQueue this
         0: .line 112
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
    Signature: ()Ljava/util/Iterator<TT;>;

  public java.lang.Object[] toArray();
    descriptor: ()[Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
         0: .line 117
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;

  public <R> R[] toArray();
    descriptor: ([Ljava/lang/Object;)[Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.lang.Object[] a
         0: .line 122
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 1 // java.lang.Object[] a
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    1     1     a  [Ljava/lang/Object;
    Signature: <R:Ljava/lang/Object;>([TR;)[TR;
    MethodParameters:
      Name  Flags
      a     

  public boolean remove(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.lang.Object o
         0: .line 127
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 1 // java.lang.Object o
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    1     1     o  Ljava/lang/Object;
    MethodParameters:
      Name  Flags
      o     

  public boolean containsAll(java.util.Collection<?>);
    descriptor: (Ljava/util/Collection;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.util.Collection c
         0: .line 132
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 1 // java.util.Collection c
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    1     1     c  Ljava/util/Collection<*>;
    Signature: (Ljava/util/Collection<*>;)Z
    MethodParameters:
      Name  Flags
      c     

  public boolean addAll(java.util.Collection<? extends T>);
    descriptor: (Ljava/util/Collection;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.util.Collection c
         0: .line 137
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 1 // java.util.Collection c
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    1     1     c  Ljava/util/Collection<+TT;>;
    Signature: (Ljava/util/Collection<+TT;>;)Z
    MethodParameters:
      Name  Flags
      c     

  public boolean removeAll(java.util.Collection<?>);
    descriptor: (Ljava/util/Collection;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.util.Collection c
         0: .line 142
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 1 // java.util.Collection c
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    1     1     c  Ljava/util/Collection<*>;
    Signature: (Ljava/util/Collection<*>;)Z
    MethodParameters:
      Name  Flags
      c     

  public boolean retainAll(java.util.Collection<?>);
    descriptor: (Ljava/util/Collection;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.util.Collection c
         0: .line 147
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 1 // java.util.Collection c
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    1     1     c  Ljava/util/Collection<*>;
    Signature: (Ljava/util/Collection<*>;)Z
    MethodParameters:
      Name  Flags
      c     

  public boolean add();
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
        start local 1 // java.lang.Object e
         0: .line 152
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 1 // java.lang.Object e
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
            0    1     1     e  TT;
    Signature: (TT;)Z
    MethodParameters:
      Name  Flags
      e     

  public T remove();
    descriptor: ()Ljava/lang/Object;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // reactor.util.concurrent.SpscArrayQueue this
         0: .line 157
            new java.lang.UnsupportedOperationException
            dup
            invokespecial java.lang.UnsupportedOperationException.<init>:()V
            athrow
        end local 0 // reactor.util.concurrent.SpscArrayQueue this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/util/concurrent/SpscArrayQueue<TT;>;
    Signature: ()TT;

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