final class reactor.core.scheduler.BoundedElasticScheduler$BoundedServices extends java.util.concurrent.atomic.AtomicInteger implements reactor.core.Disposable
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: reactor.core.scheduler.BoundedElasticScheduler$BoundedServices
super_class: java.util.concurrent.atomic.AtomicInteger
{
static final int DISPOSED;
descriptor: I
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: -1
static final java.time.ZoneId ZONE_UTC;
descriptor: Ljava/time/ZoneId;
flags: (0x0018) ACC_STATIC, ACC_FINAL
final reactor.core.scheduler.BoundedElasticScheduler parent;
descriptor: Lreactor/core/scheduler/BoundedElasticScheduler;
flags: (0x0010) ACC_FINAL
final java.time.Clock clock;
descriptor: Ljava/time/Clock;
flags: (0x0010) ACC_FINAL
final java.util.Deque<reactor.core.scheduler.BoundedElasticScheduler$BoundedState> idleQueue;
descriptor: Ljava/util/Deque;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/Deque<Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;>;
final java.util.concurrent.PriorityBlockingQueue<reactor.core.scheduler.BoundedElasticScheduler$BoundedState> busyQueue;
descriptor: Ljava/util/concurrent/PriorityBlockingQueue;
flags: (0x0010) ACC_FINAL
Signature: Ljava/util/concurrent/PriorityBlockingQueue<Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc "UTC"
invokestatic java.time.ZoneId.of:(Ljava/lang/String;)Ljava/time/ZoneId;
putstatic reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.ZONE_UTC:Ljava/time/ZoneId;
return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
1: aload 0
aconst_null
putfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.parent:Lreactor/core/scheduler/BoundedElasticScheduler;
2: aload 0
getstatic java.time.Instant.EPOCH:Ljava/time/Instant;
getstatic reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.ZONE_UTC:Ljava/time/ZoneId;
invokestatic java.time.Clock.fixed:(Ljava/time/Instant;Ljava/time/ZoneId;)Ljava/time/Clock;
putfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.clock:Ljava/time/Clock;
3: aload 0
new java.util.concurrent.PriorityBlockingQueue
dup
invokespecial java.util.concurrent.PriorityBlockingQueue.<init>:()V
putfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.busyQueue:Ljava/util/concurrent/PriorityBlockingQueue;
4: aload 0
new java.util.concurrent.ConcurrentLinkedDeque
dup
invokespecial java.util.concurrent.ConcurrentLinkedDeque.<init>:()V
putfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.idleQueue:Ljava/util/Deque;
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lreactor/core/scheduler/BoundedElasticScheduler$BoundedServices;
void <init>(reactor.core.scheduler.BoundedElasticScheduler);
descriptor: (Lreactor/core/scheduler/BoundedElasticScheduler;)V
flags: (0x0000)
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.util.concurrent.atomic.AtomicInteger.<init>:()V
1: aload 0
aload 1
putfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.parent:Lreactor/core/scheduler/BoundedElasticScheduler;
2: aload 0
aload 1
getfield reactor.core.scheduler.BoundedElasticScheduler.clock:Ljava/time/Clock;
putfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.clock:Ljava/time/Clock;
3: aload 0
new java.util.concurrent.PriorityBlockingQueue
dup
aload 1
getfield reactor.core.scheduler.BoundedElasticScheduler.maxThreads:I
4: invokedynamic applyAsInt()Ljava/util/function/ToIntFunction;
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;)I
reactor/core/scheduler/BoundedElasticScheduler$BoundedServices.lambda$0(Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;)I (6)
(Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;)I
invokestatic java.util.Comparator.comparingInt:(Ljava/util/function/ToIntFunction;)Ljava/util/Comparator;
invokespecial java.util.concurrent.PriorityBlockingQueue.<init>:(ILjava/util/Comparator;)V
5: putfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.busyQueue:Ljava/util/concurrent/PriorityBlockingQueue;
6: aload 0
new java.util.concurrent.ConcurrentLinkedDeque
dup
invokespecial java.util.concurrent.ConcurrentLinkedDeque.<init>:()V
putfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.idleQueue:Ljava/util/Deque;
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lreactor/core/scheduler/BoundedElasticScheduler$BoundedServices;
0 8 1 parent Lreactor/core/scheduler/BoundedElasticScheduler;
MethodParameters:
Name Flags
parent
void eviction();
descriptor: ()V
flags: (0x0000)
Code:
stack=5, locals=6, args_size=1
start local 0 0: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.parent:Lreactor/core/scheduler/BoundedElasticScheduler;
getfield reactor.core.scheduler.BoundedElasticScheduler.clock:Ljava/time/Clock;
invokevirtual java.time.Clock.millis:()J
lstore 1
start local 1 1: new java.util.ArrayList
dup
aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.idleQueue:Ljava/util/Deque;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
astore 3
start local 3 2: aload 3
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 5
goto 7
StackMap locals: reactor.core.scheduler.BoundedElasticScheduler$BoundedServices long java.util.List top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast reactor.core.scheduler.BoundedElasticScheduler$BoundedState
astore 4
start local 4 4: aload 4
lload 1
aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.parent:Lreactor/core/scheduler/BoundedElasticScheduler;
getfield reactor.core.scheduler.BoundedElasticScheduler.ttlMillis:J
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedState.tryEvict:(JJ)Z
ifeq 7
5: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.idleQueue:Ljava/util/Deque;
aload 4
invokeinterface java.util.Deque.remove:(Ljava/lang/Object;)Z
pop
6: aload 0
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.decrementAndGet:()I
pop
end local 4 7: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
8: return
end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lreactor/core/scheduler/BoundedElasticScheduler$BoundedServices;
1 9 1 evictionTimestamp J
2 9 3 idleCandidates Ljava/util/List<Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;>;
4 7 4 candidate Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;
reactor.core.scheduler.BoundedElasticScheduler$BoundedState pick();
descriptor: ()Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;
flags: (0x0000)
Code:
stack=4, locals=4, args_size=1
start local 0 0: StackMap locals:
StackMap stack:
aload 0
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.get:()I
istore 1
start local 1 1: iload 1
iconst_m1
if_icmpne 3
2: getstatic reactor.core.scheduler.BoundedElasticScheduler.CREATING:Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;
areturn
3: StackMap locals: int
StackMap stack:
aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.idleQueue:Ljava/util/Deque;
invokeinterface java.util.Deque.isEmpty:()Z
ifne 8
4: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.idleQueue:Ljava/util/Deque;
invokeinterface java.util.Deque.pollLast:()Ljava/lang/Object;
checkcast reactor.core.scheduler.BoundedElasticScheduler$BoundedState
astore 2
start local 2 5: aload 2
ifnull 0
aload 2
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedState.markPicked:()Z
ifeq 0
6: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.busyQueue:Ljava/util/concurrent/PriorityBlockingQueue;
aload 2
invokevirtual java.util.concurrent.PriorityBlockingQueue.add:(Ljava/lang/Object;)Z
pop
7: aload 2
areturn
end local 2 8: StackMap locals:
StackMap stack:
iload 1
aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.parent:Lreactor/core/scheduler/BoundedElasticScheduler;
getfield reactor.core.scheduler.BoundedElasticScheduler.maxThreads:I
if_icmpge 15
9: aload 0
iload 1
iload 1
iconst_1
iadd
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.compareAndSet:(II)Z
ifeq 0
10: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.parent:Lreactor/core/scheduler/BoundedElasticScheduler;
aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.parent:Lreactor/core/scheduler/BoundedElasticScheduler;
invokevirtual reactor.core.scheduler.BoundedElasticScheduler.createBoundedExecutorService:()Lreactor/core/scheduler/BoundedElasticScheduler$BoundedScheduledExecutorService;
invokestatic reactor.core.scheduler.Schedulers.decorateExecutorService:(Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;)Ljava/util/concurrent/ScheduledExecutorService;
astore 2
start local 2 11: new reactor.core.scheduler.BoundedElasticScheduler$BoundedState
dup
aload 0
aload 2
invokespecial reactor.core.scheduler.BoundedElasticScheduler$BoundedState.<init>:(Lreactor/core/scheduler/BoundedElasticScheduler$BoundedServices;Ljava/util/concurrent/ScheduledExecutorService;)V
astore 3
start local 3 12: aload 3
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedState.markPicked:()Z
ifeq 0
13: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.busyQueue:Ljava/util/concurrent/PriorityBlockingQueue;
aload 3
invokevirtual java.util.concurrent.PriorityBlockingQueue.add:(Ljava/lang/Object;)Z
pop
14: aload 3
areturn
end local 3 end local 2 15: StackMap locals:
StackMap stack:
aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.busyQueue:Ljava/util/concurrent/PriorityBlockingQueue;
invokevirtual java.util.concurrent.PriorityBlockingQueue.poll:()Ljava/lang/Object;
checkcast reactor.core.scheduler.BoundedElasticScheduler$BoundedState
astore 2
start local 2 16: aload 2
ifnull 0
aload 2
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedState.markPicked:()Z
ifeq 0
17: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.busyQueue:Ljava/util/concurrent/PriorityBlockingQueue;
aload 2
invokevirtual java.util.concurrent.PriorityBlockingQueue.add:(Ljava/lang/Object;)Z
pop
18: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 this Lreactor/core/scheduler/BoundedElasticScheduler$BoundedServices;
1 19 1 a I
5 8 2 bs Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;
11 15 2 s Ljava/util/concurrent/ScheduledExecutorService;
12 15 3 newState Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;
16 19 2 s Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;
void setIdle(reactor.core.scheduler.BoundedElasticScheduler$BoundedState);
descriptor: (Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;)V
flags: (0x0000)
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.busyQueue:Ljava/util/concurrent/PriorityBlockingQueue;
aload 1
invokevirtual java.util.concurrent.PriorityBlockingQueue.remove:(Ljava/lang/Object;)Z
ifeq 2
1: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.idleQueue:Ljava/util/Deque;
aload 1
invokeinterface java.util.Deque.add:(Ljava/lang/Object;)Z
pop
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lreactor/core/scheduler/BoundedElasticScheduler$BoundedServices;
0 3 1 boundedState Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;
MethodParameters:
Name Flags
boundedState
public boolean isDisposed();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.get:()I
iconst_m1
if_icmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lreactor/core/scheduler/BoundedElasticScheduler$BoundedServices;
public void dispose();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_m1
invokevirtual reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.set:(I)V
1: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.idleQueue:Ljava/util/Deque;
invokedynamic accept()Ljava/util/function/Consumer;
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;)V
reactor/core/scheduler/BoundedElasticScheduler$BoundedState.shutdown()V (5)
(Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;)V
invokeinterface java.util.Deque.forEach:(Ljava/util/function/Consumer;)V
2: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedServices.busyQueue:Ljava/util/concurrent/PriorityBlockingQueue;
invokedynamic accept()Ljava/util/function/Consumer;
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;)V
reactor/core/scheduler/BoundedElasticScheduler$BoundedState.shutdown()V (5)
(Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;)V
invokevirtual java.util.concurrent.PriorityBlockingQueue.forEach:(Ljava/util/function/Consumer;)V
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lreactor/core/scheduler/BoundedElasticScheduler$BoundedServices;
private static int lambda$0(reactor.core.scheduler.BoundedElasticScheduler$BoundedState);
descriptor: (Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;)I
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield reactor.core.scheduler.BoundedElasticScheduler$BoundedState.markCount:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 bs Lreactor/core/scheduler/BoundedElasticScheduler$BoundedState;
}
SourceFile: "BoundedElasticScheduler.java"
NestHost: reactor.core.scheduler.BoundedElasticScheduler
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
final BoundedScheduledExecutorService = reactor.core.scheduler.BoundedElasticScheduler$BoundedScheduledExecutorService of reactor.core.scheduler.BoundedElasticScheduler
final BoundedServices = reactor.core.scheduler.BoundedElasticScheduler$BoundedServices of reactor.core.scheduler.BoundedElasticScheduler
BoundedState = reactor.core.scheduler.BoundedElasticScheduler$BoundedState of reactor.core.scheduler.BoundedElasticScheduler