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

Queues
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
public final class reactor.util.concurrent.Queues
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: reactor.util.concurrent.Queues
  super_class: java.lang.Object
{
  public static final int CAPACITY_UNSURE;
    descriptor: I
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: -2147483648

  public static final int XS_BUFFER_SIZE;
    descriptor: I
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL

  public static final int SMALL_BUFFER_SIZE;
    descriptor: I
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL

  static final java.util.function.Supplier ZERO_SUPPLIER;
    descriptor: Ljava/util/function/Supplier;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static final java.util.function.Supplier ONE_SUPPLIER;
    descriptor: Ljava/util/function/Supplier;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static final java.util.function.Supplier XS_SUPPLIER;
    descriptor: Ljava/util/function/Supplier;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static final java.util.function.Supplier SMALL_SUPPLIER;
    descriptor: Ljava/util/function/Supplier;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static final java.util.function.Supplier SMALL_UNBOUNDED;
    descriptor: Ljava/util/function/Supplier;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static final java.util.function.Supplier XS_UNBOUNDED;
    descriptor: Ljava/util/function/Supplier;
    flags: (0x0018) ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 82
            bipush 8
         1: .line 83
            ldc "reactor.bufferSize.x"
            ldc "32"
            invokestatic java.lang.System.getProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
         2: .line 82
            invokestatic java.lang.Math.max:(II)I
            putstatic reactor.util.concurrent.Queues.XS_BUFFER_SIZE:I
         3: .line 88
            bipush 16
         4: .line 89
            ldc "reactor.bufferSize.small"
            ldc "256"
            invokestatic java.lang.System.getProperty:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
            invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
         5: .line 88
            invokestatic java.lang.Math.max:(II)I
            putstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
         6: .line 480
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/Queues$ZeroQueue.<init>()V (8)
                  ()Ljava/lang/Object;
            putstatic reactor.util.concurrent.Queues.ZERO_SUPPLIER:Ljava/util/function/Supplier;
         7: .line 482
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/Queues$OneQueue.<init>()V (8)
                  ()Ljava/lang/Object;
            putstatic reactor.util.concurrent.Queues.ONE_SUPPLIER:Ljava/util/function/Supplier;
         8: .line 484
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/Queues.lambda$2()Ljava/lang/Object; (6)
                  ()Ljava/lang/Object;
            putstatic reactor.util.concurrent.Queues.XS_SUPPLIER:Ljava/util/function/Supplier;
         9: .line 486
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/Queues.lambda$3()Ljava/lang/Object; (6)
                  ()Ljava/lang/Object;
            putstatic reactor.util.concurrent.Queues.SMALL_SUPPLIER:Ljava/util/function/Supplier;
        10: .line 489
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/Queues.lambda$4()Ljava/lang/Object; (6)
                  ()Ljava/lang/Object;
        11: .line 488
            putstatic reactor.util.concurrent.Queues.SMALL_UNBOUNDED:Ljava/util/function/Supplier;
        12: .line 491
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/Queues.lambda$5()Ljava/lang/Object; (6)
                  ()Ljava/lang/Object;
            putstatic reactor.util.concurrent.Queues.XS_UNBOUNDED:Ljava/util/function/Supplier;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public static final int capacity(java.util.Queue);
    descriptor: (Ljava/util/Queue;)I
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // java.util.Queue q
         0: .line 52
            aload 0 /* q */
            instanceof reactor.util.concurrent.Queues$ZeroQueue
            ifeq 2
         1: .line 53
            iconst_0
            ireturn
         2: .line 55
      StackMap locals:
      StackMap stack:
            aload 0 /* q */
            instanceof reactor.util.concurrent.Queues$OneQueue
            ifeq 4
         3: .line 56
            iconst_1
            ireturn
         4: .line 58
      StackMap locals:
      StackMap stack:
            aload 0 /* q */
            instanceof reactor.util.concurrent.SpscLinkedArrayQueue
            ifeq 6
         5: .line 59
            ldc 2147483647
            ireturn
         6: .line 61
      StackMap locals:
      StackMap stack:
            aload 0 /* q */
            instanceof reactor.util.concurrent.SpscArrayQueue
            ifeq 8
         7: .line 62
            aload 0 /* q */
            checkcast reactor.util.concurrent.SpscArrayQueue
            invokevirtual reactor.util.concurrent.SpscArrayQueue.length:()I
            ireturn
         8: .line 64
      StackMap locals:
      StackMap stack:
            aload 0 /* q */
            instanceof reactor.util.concurrent.MpscLinkedQueue
            ifeq 10
         9: .line 65
            ldc 2147483647
            ireturn
        10: .line 67
      StackMap locals:
      StackMap stack:
            aload 0 /* q */
            instanceof java.util.concurrent.BlockingQueue
            ifeq 12
        11: .line 68
            aload 0 /* q */
            checkcast java.util.concurrent.BlockingQueue
            invokeinterface java.util.concurrent.BlockingQueue.remainingCapacity:()I
            ireturn
        12: .line 70
      StackMap locals:
      StackMap stack:
            aload 0 /* q */
            instanceof java.util.concurrent.ConcurrentLinkedQueue
            ifeq 14
        13: .line 71
            ldc 2147483647
            ireturn
        14: .line 74
      StackMap locals:
      StackMap stack:
            ldc -2147483648
            ireturn
        end local 0 // java.util.Queue q
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   15     0     q  Ljava/util/Queue;
    MethodParameters:
      Name  Flags
      q     

  public static int ceilingNextPowerOfTwo(int);
    descriptor: (I)I
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // int x
         0: .line 100
            iconst_1
            bipush 32
            iload 0 /* x */
            iconst_1
            isub
            invokestatic java.lang.Integer.numberOfLeadingZeros:(I)I
            isub
            ishl
            ireturn
        end local 0 // int x
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     x  I
    MethodParameters:
      Name  Flags
      x     final

  public static <T> java.util.function.Supplier<java.util.Queue<T>> get(int);
    descriptor: (I)Ljava/util/function/Supplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // int batchSize
         0: .line 111
            iload 0 /* batchSize */
            ldc 2147483647
            if_icmpne 2
         1: .line 112
            getstatic reactor.util.concurrent.Queues.SMALL_UNBOUNDED:Ljava/util/function/Supplier;
            areturn
         2: .line 114
      StackMap locals:
      StackMap stack:
            iload 0 /* batchSize */
            getstatic reactor.util.concurrent.Queues.XS_BUFFER_SIZE:I
            if_icmpne 4
         3: .line 115
            getstatic reactor.util.concurrent.Queues.XS_SUPPLIER:Ljava/util/function/Supplier;
            areturn
         4: .line 117
      StackMap locals:
      StackMap stack:
            iload 0 /* batchSize */
            getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
            if_icmpne 6
         5: .line 118
            getstatic reactor.util.concurrent.Queues.SMALL_SUPPLIER:Ljava/util/function/Supplier;
            areturn
         6: .line 120
      StackMap locals:
      StackMap stack:
            iload 0 /* batchSize */
            iconst_1
            if_icmpne 8
         7: .line 121
            getstatic reactor.util.concurrent.Queues.ONE_SUPPLIER:Ljava/util/function/Supplier;
            areturn
         8: .line 123
      StackMap locals:
      StackMap stack:
            iload 0 /* batchSize */
            ifne 10
         9: .line 124
            getstatic reactor.util.concurrent.Queues.ZERO_SUPPLIER:Ljava/util/function/Supplier;
            areturn
        10: .line 127
      StackMap locals:
      StackMap stack:
            bipush 8
            iload 0 /* batchSize */
            invokestatic java.lang.Math.max:(II)I
            istore 1 /* adjustedBatchSize */
        start local 1 // int adjustedBatchSize
        11: .line 128
            iload 1 /* adjustedBatchSize */
            ldc 10000000
            if_icmple 13
        12: .line 129
            getstatic reactor.util.concurrent.Queues.SMALL_UNBOUNDED:Ljava/util/function/Supplier;
            areturn
        13: .line 132
      StackMap locals: int
      StackMap stack:
            iload 1 /* adjustedBatchSize */
            invokedynamic get(I)Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/Queues.lambda$6(I)Ljava/util/Queue; (6)
                  ()Ljava/util/Queue;
            areturn
        end local 1 // int adjustedBatchSize
        end local 0 // int batchSize
      LocalVariableTable:
        Start  End  Slot               Name  Signature
            0   14     0          batchSize  I
           11   14     1  adjustedBatchSize  I
    Signature: <T:Ljava/lang/Object;>(I)Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;
    MethodParameters:
           Name  Flags
      batchSize  

  public static boolean isPowerOfTwo(int);
    descriptor: (I)Z
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // int x
         0: .line 142
            iload 0 /* x */
            invokestatic java.lang.Integer.bitCount:(I)I
            iconst_1
            if_icmpne 1
            iconst_1
            ireturn
      StackMap locals:
      StackMap stack:
         1: iconst_0
            ireturn
        end local 0 // int x
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0     x  I
    MethodParameters:
      Name  Flags
      x     final

  public static <T> java.util.function.Supplier<java.util.Queue<T>> empty();
    descriptor: ()Ljava/util/function/Supplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 155
            getstatic reactor.util.concurrent.Queues.ZERO_SUPPLIER:Ljava/util/function/Supplier;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>()Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;

  public static <T> java.util.function.Supplier<java.util.Queue<T>> one();
    descriptor: ()Ljava/util/function/Supplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 165
            getstatic reactor.util.concurrent.Queues.ONE_SUPPLIER:Ljava/util/function/Supplier;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>()Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;

  public static <T> java.util.function.Supplier<java.util.Queue<T>> small();
    descriptor: ()Ljava/util/function/Supplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 175
            getstatic reactor.util.concurrent.Queues.SMALL_SUPPLIER:Ljava/util/function/Supplier;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>()Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;

  public static <T> java.util.function.Supplier<java.util.Queue<T>> unbounded();
    descriptor: ()Ljava/util/function/Supplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 185
            getstatic reactor.util.concurrent.Queues.SMALL_UNBOUNDED:Ljava/util/function/Supplier;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>()Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;

  public static <T> java.util.function.Supplier<java.util.Queue<T>> unbounded(int);
    descriptor: (I)Ljava/util/function/Supplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // int linkSize
         0: .line 197
            iload 0 /* linkSize */
            getstatic reactor.util.concurrent.Queues.XS_BUFFER_SIZE:I
            if_icmpne 2
         1: .line 198
            getstatic reactor.util.concurrent.Queues.XS_UNBOUNDED:Ljava/util/function/Supplier;
            areturn
         2: .line 200
      StackMap locals:
      StackMap stack:
            iload 0 /* linkSize */
            ldc 2147483647
            if_icmpeq 3
            iload 0 /* linkSize */
            getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
            if_icmpne 4
         3: .line 201
      StackMap locals:
      StackMap stack:
            invokestatic reactor.util.concurrent.Queues.unbounded:()Ljava/util/function/Supplier;
            areturn
         4: .line 203
      StackMap locals:
      StackMap stack:
            iload 0 /* linkSize */
            invokedynamic get(I)Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/Queues.lambda$7(I)Ljava/util/Queue; (6)
                  ()Ljava/util/Queue;
            areturn
        end local 0 // int linkSize
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    5     0  linkSize  I
    Signature: <T:Ljava/lang/Object;>(I)Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;
    MethodParameters:
          Name  Flags
      linkSize  

  public static <T> java.util.function.Supplier<java.util.Queue<T>> xs();
    descriptor: ()Ljava/util/function/Supplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 213
            getstatic reactor.util.concurrent.Queues.XS_SUPPLIER:Ljava/util/function/Supplier;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>()Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;

  public static <T> java.util.function.Supplier<java.util.Queue<T>> unboundedMultiproducer();
    descriptor: ()Ljava/util/function/Supplier;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 224
            invokedynamic get()Ljava/util/function/Supplier;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  ()Ljava/lang/Object;
                  reactor/util/concurrent/MpscLinkedQueue.<init>()V (8)
                  ()Ljava/util/Queue;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Signature: <T:Ljava/lang/Object;>()Ljava/util/function/Supplier<Ljava/util/Queue<TT;>;>;

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.util.concurrent.Queues this
         0: .line 227
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 229
            return
        end local 0 // reactor.util.concurrent.Queues this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lreactor/util/concurrent/Queues;

  private static java.lang.Object lambda$2();
    descriptor: ()Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 484
            new reactor.util.concurrent.SpscArrayQueue
            dup
            getstatic reactor.util.concurrent.Queues.XS_BUFFER_SIZE:I
            invokespecial reactor.util.concurrent.SpscArrayQueue.<init>:(I)V
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static java.lang.Object lambda$3();
    descriptor: ()Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 486
            new reactor.util.concurrent.SpscArrayQueue
            dup
            getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
            invokespecial reactor.util.concurrent.SpscArrayQueue.<init>:(I)V
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static java.lang.Object lambda$4();
    descriptor: ()Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 489
            new reactor.util.concurrent.SpscLinkedArrayQueue
            dup
            getstatic reactor.util.concurrent.Queues.SMALL_BUFFER_SIZE:I
            invokespecial reactor.util.concurrent.SpscLinkedArrayQueue.<init>:(I)V
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static java.lang.Object lambda$5();
    descriptor: ()Ljava/lang/Object;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 491
            new reactor.util.concurrent.SpscLinkedArrayQueue
            dup
            getstatic reactor.util.concurrent.Queues.XS_BUFFER_SIZE:I
            invokespecial reactor.util.concurrent.SpscLinkedArrayQueue.<init>:(I)V
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static java.util.Queue lambda$6(int);
    descriptor: (I)Ljava/util/Queue;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 132
            new reactor.util.concurrent.SpscArrayQueue
            dup
            iload 0
            invokespecial reactor.util.concurrent.SpscArrayQueue.<init>:(I)V
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private static java.util.Queue lambda$7(int);
    descriptor: (I)Ljava/util/Queue;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=3, locals=1, args_size=1
         0: .line 203
            new reactor.util.concurrent.SpscLinkedArrayQueue
            dup
            iload 0
            invokespecial reactor.util.concurrent.SpscLinkedArrayQueue.<init>:(I)V
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
SourceFile: "Queues.java"
NestMembers:
  reactor.util.concurrent.Queues$OneQueue  reactor.util.concurrent.Queues$QueueIterator  reactor.util.concurrent.Queues$ZeroQueue
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  final OneQueue = reactor.util.concurrent.Queues$OneQueue of reactor.util.concurrent.Queues
  final QueueIterator = reactor.util.concurrent.Queues$QueueIterator of reactor.util.concurrent.Queues
  final ZeroQueue = reactor.util.concurrent.Queues$ZeroQueue of reactor.util.concurrent.Queues
/

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