public abstract class reactor.core.scheduler.Schedulers
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: reactor.core.scheduler.Schedulers
super_class: java.lang.Object
{
public static final int DEFAULT_POOL_SIZE;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
public static final int DEFAULT_BOUNDED_ELASTIC_SIZE;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
public static final int DEFAULT_BOUNDED_ELASTIC_QUEUESIZE;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
static volatile java.util.function.BiConsumer<java.lang.Thread, ? super java.lang.Throwable> onHandleErrorHook;
descriptor: Ljava/util/function/BiConsumer;
flags: (0x0048) ACC_STATIC, ACC_VOLATILE
Signature: Ljava/util/function/BiConsumer<Ljava/lang/Thread;-Ljava/lang/Throwable;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
static final java.lang.String ELASTIC;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "elastic"
static final java.lang.String BOUNDED_ELASTIC;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "boundedElastic"
static final java.lang.String PARALLEL;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "parallel"
static final java.lang.String SINGLE;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "single"
static final java.lang.String IMMEDIATE;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "immediate"
static final java.lang.String FROM_EXECUTOR;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "fromExecutor"
static final java.lang.String FROM_EXECUTOR_SERVICE;
descriptor: Ljava/lang/String;
flags: (0x0018) ACC_STATIC, ACC_FINAL
ConstantValue: "fromExecutorService"
static java.util.concurrent.atomic.AtomicReference<reactor.core.scheduler.Schedulers$CachedScheduler> CACHED_ELASTIC;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0008) ACC_STATIC
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lreactor/core/scheduler/Schedulers$CachedScheduler;>;
static java.util.concurrent.atomic.AtomicReference<reactor.core.scheduler.Schedulers$CachedScheduler> CACHED_BOUNDED_ELASTIC;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0008) ACC_STATIC
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lreactor/core/scheduler/Schedulers$CachedScheduler;>;
static java.util.concurrent.atomic.AtomicReference<reactor.core.scheduler.Schedulers$CachedScheduler> CACHED_PARALLEL;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0008) ACC_STATIC
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lreactor/core/scheduler/Schedulers$CachedScheduler;>;
static java.util.concurrent.atomic.AtomicReference<reactor.core.scheduler.Schedulers$CachedScheduler> CACHED_SINGLE;
descriptor: Ljava/util/concurrent/atomic/AtomicReference;
flags: (0x0008) ACC_STATIC
Signature: Ljava/util/concurrent/atomic/AtomicReference<Lreactor/core/scheduler/Schedulers$CachedScheduler;>;
static final java.util.function.Supplier<reactor.core.scheduler.Scheduler> ELASTIC_SUPPLIER;
descriptor: Ljava/util/function/Supplier;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;
static final java.util.function.Supplier<reactor.core.scheduler.Scheduler> BOUNDED_ELASTIC_SUPPLIER;
descriptor: Ljava/util/function/Supplier;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;
static final java.util.function.Supplier<reactor.core.scheduler.Scheduler> PARALLEL_SUPPLIER;
descriptor: Ljava/util/function/Supplier;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;
static final java.util.function.Supplier<reactor.core.scheduler.Scheduler> SINGLE_SUPPLIER;
descriptor: Ljava/util/function/Supplier;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;
static final reactor.core.scheduler.Schedulers$Factory DEFAULT;
descriptor: Lreactor/core/scheduler/Schedulers$Factory;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static final java.util.Map<java.lang.String, java.util.function.BiFunction<reactor.core.scheduler.Scheduler, java.util.concurrent.ScheduledExecutorService, java.util.concurrent.ScheduledExecutorService>> DECORATORS;
descriptor: Ljava/util/Map;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/Map<Ljava/lang/String;Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;>;
static volatile reactor.core.scheduler.Schedulers$Factory factory;
descriptor: Lreactor/core/scheduler/Schedulers$Factory;
flags: (0x0048) ACC_STATIC, ACC_VOLATILE
private static final java.util.LinkedHashMap<java.lang.String, java.util.function.Function<java.lang.Runnable, java.lang.Runnable>> onScheduleHooks;
descriptor: Ljava/util/LinkedHashMap;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Signature: Ljava/util/LinkedHashMap<Ljava/lang/String;Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;>;
private static java.util.function.Function<java.lang.Runnable, java.lang.Runnable> onScheduleHook;
descriptor: Ljava/util/function/Function;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Signature: Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
static final reactor.util.Logger LOGGER;
descriptor: Lreactor/util/Logger;
flags: (0x0018) ACC_STATIC, ACC_FINAL
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: ldc "reactor.schedulers.defaultPoolSize"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
invokestatic java.util.Optional.ofNullable:(Ljava/lang/Object;)Ljava/util/Optional;
1: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/lang/Integer.parseInt(Ljava/lang/String;)I (6)
(Ljava/lang/String;)Ljava/lang/Integer;
invokevirtual java.util.Optional.map:(Ljava/util/function/Function;)Ljava/util/Optional;
2: 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/core/scheduler/Schedulers.lambda$1()Ljava/lang/Integer; (6)
()Ljava/lang/Integer;
invokevirtual java.util.Optional.orElseGet:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
3: putstatic reactor.core.scheduler.Schedulers.DEFAULT_POOL_SIZE:I
4: ldc "reactor.schedulers.defaultBoundedElasticSize"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
invokestatic java.util.Optional.ofNullable:(Ljava/lang/Object;)Ljava/util/Optional;
5: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/lang/Integer.parseInt(Ljava/lang/String;)I (6)
(Ljava/lang/String;)Ljava/lang/Integer;
invokevirtual java.util.Optional.map:(Ljava/util/function/Function;)Ljava/util/Optional;
6: 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/core/scheduler/Schedulers.lambda$3()Ljava/lang/Integer; (6)
()Ljava/lang/Integer;
invokevirtual java.util.Optional.orElseGet:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
7: putstatic reactor.core.scheduler.Schedulers.DEFAULT_BOUNDED_ELASTIC_SIZE:I
8: ldc "reactor.schedulers.defaultBoundedElasticQueueSize"
invokestatic java.lang.System.getProperty:(Ljava/lang/String;)Ljava/lang/String;
invokestatic java.util.Optional.ofNullable:(Ljava/lang/Object;)Ljava/util/Optional;
9: invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/lang/Integer.parseInt(Ljava/lang/String;)I (6)
(Ljava/lang/String;)Ljava/lang/Integer;
invokevirtual java.util.Optional.map:(Ljava/util/function/Function;)Ljava/util/Optional;
10: ldc 100000
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
invokevirtual java.util.Optional.orElse:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Integer
invokevirtual java.lang.Integer.intValue:()I
11: putstatic reactor.core.scheduler.Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE:I
12: new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putstatic reactor.core.scheduler.Schedulers.CACHED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
13: new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putstatic reactor.core.scheduler.Schedulers.CACHED_BOUNDED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
14: new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putstatic reactor.core.scheduler.Schedulers.CACHED_PARALLEL:Ljava/util/concurrent/atomic/AtomicReference;
15: new java.util.concurrent.atomic.AtomicReference
dup
invokespecial java.util.concurrent.atomic.AtomicReference.<init>:()V
putstatic reactor.core.scheduler.Schedulers.CACHED_SINGLE:Ljava/util/concurrent/atomic/AtomicReference;
16: 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/core/scheduler/Schedulers.lambda$5()Lreactor/core/scheduler/Scheduler; (6)
()Lreactor/core/scheduler/Scheduler;
17: putstatic reactor.core.scheduler.Schedulers.ELASTIC_SUPPLIER:Ljava/util/function/Supplier;
18: 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/core/scheduler/Schedulers.lambda$6()Lreactor/core/scheduler/Scheduler; (6)
()Lreactor/core/scheduler/Scheduler;
19: putstatic reactor.core.scheduler.Schedulers.BOUNDED_ELASTIC_SUPPLIER:Ljava/util/function/Supplier;
20: 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/core/scheduler/Schedulers.lambda$7()Lreactor/core/scheduler/Scheduler; (6)
()Lreactor/core/scheduler/Scheduler;
21: putstatic reactor.core.scheduler.Schedulers.PARALLEL_SUPPLIER:Ljava/util/function/Supplier;
22: 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/core/scheduler/Schedulers.lambda$8()Lreactor/core/scheduler/Scheduler; (6)
()Lreactor/core/scheduler/Scheduler;
putstatic reactor.core.scheduler.Schedulers.SINGLE_SUPPLIER:Ljava/util/function/Supplier;
23: new reactor.core.scheduler.Schedulers$1
dup
invokespecial reactor.core.scheduler.Schedulers$1.<init>:()V
putstatic reactor.core.scheduler.Schedulers.DEFAULT:Lreactor/core/scheduler/Schedulers$Factory;
24: new java.util.LinkedHashMap
dup
invokespecial java.util.LinkedHashMap.<init>:()V
putstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
25: getstatic reactor.core.scheduler.Schedulers.DEFAULT:Lreactor/core/scheduler/Schedulers$Factory;
putstatic reactor.core.scheduler.Schedulers.factory:Lreactor/core/scheduler/Schedulers$Factory;
26: new java.util.LinkedHashMap
dup
iconst_1
invokespecial java.util.LinkedHashMap.<init>:(I)V
putstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
27: ldc Lreactor/core/scheduler/Schedulers;
invokestatic reactor.util.Loggers.getLogger:(Ljava/lang/Class;)Lreactor/util/Logger;
putstatic reactor.core.scheduler.Schedulers.LOGGER:Lreactor/util/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/scheduler/Schedulers;
public static reactor.core.scheduler.Scheduler fromExecutor(java.util.concurrent.Executor);
descriptor: (Ljava/util/concurrent/Executor;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
invokestatic reactor.core.scheduler.Schedulers.fromExecutor:(Ljava/util/concurrent/Executor;Z)Lreactor/core/scheduler/Scheduler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 executor Ljava/util/concurrent/Executor;
MethodParameters:
Name Flags
executor
public static reactor.core.scheduler.Scheduler fromExecutor(java.util.concurrent.Executor, boolean);
descriptor: (Ljava/util/concurrent/Executor;Z)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: iload 1
ifne 2
aload 0
instanceof java.util.concurrent.ExecutorService
ifeq 2
1: aload 0
checkcast java.util.concurrent.ExecutorService
invokestatic reactor.core.scheduler.Schedulers.fromExecutorService:(Ljava/util/concurrent/ExecutorService;)Lreactor/core/scheduler/Scheduler;
areturn
2: StackMap locals:
StackMap stack:
new reactor.core.scheduler.ExecutorScheduler
dup
aload 0
iload 1
invokespecial reactor.core.scheduler.ExecutorScheduler.<init>:(Ljava/util/concurrent/Executor;Z)V
astore 2
start local 2 3: aload 2
invokevirtual reactor.core.scheduler.ExecutorScheduler.start:()V
4: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 executor Ljava/util/concurrent/Executor;
0 5 1 trampoline Z
3 5 2 scheduler Lreactor/core/scheduler/ExecutorScheduler;
MethodParameters:
Name Flags
executor
trampoline
public static reactor.core.scheduler.Scheduler fromExecutorService(java.util.concurrent.ExecutorService);
descriptor: (Ljava/util/concurrent/ExecutorService;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
invokestatic java.lang.System.identityHashCode:(Ljava/lang/Object;)I
invokestatic java.lang.Integer.toHexString:(I)Ljava/lang/String;
astore 1
start local 1 1: aload 0
new java.lang.StringBuilder
dup
ldc "anonymousExecutor@"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic reactor.core.scheduler.Schedulers.fromExecutorService:(Ljava/util/concurrent/ExecutorService;Ljava/lang/String;)Lreactor/core/scheduler/Scheduler;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 executorService Ljava/util/concurrent/ExecutorService;
1 2 1 executorServiceHashcode Ljava/lang/String;
MethodParameters:
Name Flags
executorService
public static reactor.core.scheduler.Scheduler fromExecutorService(java.util.concurrent.ExecutorService, java.lang.String);
descriptor: (Ljava/util/concurrent/ExecutorService;Ljava/lang/String;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: new reactor.core.scheduler.DelegateServiceScheduler
dup
aload 1
aload 0
invokespecial reactor.core.scheduler.DelegateServiceScheduler.<init>:(Ljava/lang/String;Ljava/util/concurrent/ExecutorService;)V
astore 2
start local 2 1: aload 2
invokevirtual reactor.core.scheduler.DelegateServiceScheduler.start:()V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 executorService Ljava/util/concurrent/ExecutorService;
0 3 1 executorName Ljava/lang/String;
1 3 2 scheduler Lreactor/core/scheduler/DelegateServiceScheduler;
MethodParameters:
Name Flags
executorService
executorName
public static reactor.core.scheduler.Scheduler elastic();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.CACHED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
ldc "elastic"
getstatic reactor.core.scheduler.Schedulers.ELASTIC_SUPPLIER:Ljava/util/function/Supplier;
invokestatic reactor.core.scheduler.Schedulers.cache:(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/String;Ljava/util/function/Supplier;)Lreactor/core/scheduler/Schedulers$CachedScheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static reactor.core.scheduler.Scheduler boundedElastic();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.CACHED_BOUNDED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
ldc "boundedElastic"
getstatic reactor.core.scheduler.Schedulers.BOUNDED_ELASTIC_SUPPLIER:Ljava/util/function/Supplier;
invokestatic reactor.core.scheduler.Schedulers.cache:(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/String;Ljava/util/function/Supplier;)Lreactor/core/scheduler/Schedulers$CachedScheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.scheduler.Scheduler parallel();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.CACHED_PARALLEL:Ljava/util/concurrent/atomic/AtomicReference;
ldc "parallel"
getstatic reactor.core.scheduler.Schedulers.PARALLEL_SUPPLIER:Ljava/util/function/Supplier;
invokestatic reactor.core.scheduler.Schedulers.cache:(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/String;Ljava/util/function/Supplier;)Lreactor/core/scheduler/Schedulers$CachedScheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.scheduler.Scheduler immediate();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic reactor.core.scheduler.ImmediateScheduler.instance:()Lreactor/core/scheduler/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.scheduler.Scheduler newElastic(java.lang.String);
descriptor: (Ljava/lang/String;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
bipush 60
invokestatic reactor.core.scheduler.Schedulers.newElastic:(Ljava/lang/String;I)Lreactor/core/scheduler/Scheduler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 name Ljava/lang/String;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
name
public static reactor.core.scheduler.Scheduler newElastic(java.lang.String, int);
descriptor: (Ljava/lang/String;I)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
iconst_0
invokestatic reactor.core.scheduler.Schedulers.newElastic:(Ljava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 name Ljava/lang/String;
0 1 1 ttlSeconds I
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
name
ttlSeconds
public static reactor.core.scheduler.Scheduler newElastic(java.lang.String, int, boolean);
descriptor: (Ljava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: iload 1
1: new reactor.core.scheduler.ReactorThreadFactory
dup
aload 0
getstatic reactor.core.scheduler.ElasticScheduler.COUNTER:Ljava/util/concurrent/atomic/AtomicLong;
iload 2
iconst_0
2: invokedynamic accept()Ljava/util/function/BiConsumer;
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;Ljava/lang/Object;)V
reactor/core/scheduler/Schedulers.defaultUncaughtException(Ljava/lang/Thread;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Thread;Ljava/lang/Throwable;)V
3: invokespecial reactor.core.scheduler.ReactorThreadFactory.<init>:(Ljava/lang/String;Ljava/util/concurrent/atomic/AtomicLong;ZZLjava/util/function/BiConsumer;)V
4: invokestatic reactor.core.scheduler.Schedulers.newElastic:(ILjava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 name Ljava/lang/String;
0 5 1 ttlSeconds I
0 5 2 daemon Z
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
name
ttlSeconds
daemon
public static reactor.core.scheduler.Scheduler newElastic(int, java.util.concurrent.ThreadFactory);
descriptor: (ILjava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic reactor.core.scheduler.Schedulers.factory:Lreactor/core/scheduler/Schedulers$Factory;
iload 0
aload 1
invokeinterface reactor.core.scheduler.Schedulers$Factory.newElastic:(ILjava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
astore 2
start local 2 1: aload 2
invokeinterface reactor.core.scheduler.Scheduler.start:()V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 ttlSeconds I
0 3 1 threadFactory Ljava/util/concurrent/ThreadFactory;
1 3 2 fromFactory Lreactor/core/scheduler/Scheduler;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
ttlSeconds
threadFactory
public static reactor.core.scheduler.Scheduler newBoundedElastic(int, int, java.lang.String);
descriptor: (IILjava/lang/String;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: iload 0
iload 1
aload 2
bipush 60
iconst_0
invokestatic reactor.core.scheduler.Schedulers.newBoundedElastic:(IILjava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 threadCap I
0 1 1 queuedTaskCap I
0 1 2 name Ljava/lang/String;
MethodParameters:
Name Flags
threadCap
queuedTaskCap
name
public static reactor.core.scheduler.Scheduler newBoundedElastic(int, int, java.lang.String, int);
descriptor: (IILjava/lang/String;I)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: iload 0
iload 1
aload 2
iload 3
iconst_0
invokestatic reactor.core.scheduler.Schedulers.newBoundedElastic:(IILjava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 threadCap I
0 1 1 queuedTaskCap I
0 1 2 name Ljava/lang/String;
0 1 3 ttlSeconds I
MethodParameters:
Name Flags
threadCap
queuedTaskCap
name
ttlSeconds
public static reactor.core.scheduler.Scheduler newBoundedElastic(int, int, java.lang.String, int, boolean);
descriptor: (IILjava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=9, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: iload 0
iload 1
1: new reactor.core.scheduler.ReactorThreadFactory
dup
aload 2
getstatic reactor.core.scheduler.ElasticScheduler.COUNTER:Ljava/util/concurrent/atomic/AtomicLong;
iload 4
iconst_0
2: invokedynamic accept()Ljava/util/function/BiConsumer;
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;Ljava/lang/Object;)V
reactor/core/scheduler/Schedulers.defaultUncaughtException(Ljava/lang/Thread;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Thread;Ljava/lang/Throwable;)V
3: invokespecial reactor.core.scheduler.ReactorThreadFactory.<init>:(Ljava/lang/String;Ljava/util/concurrent/atomic/AtomicLong;ZZLjava/util/function/BiConsumer;)V
4: iload 3
5: invokestatic reactor.core.scheduler.Schedulers.newBoundedElastic:(IILjava/util/concurrent/ThreadFactory;I)Lreactor/core/scheduler/Scheduler;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 threadCap I
0 6 1 queuedTaskCap I
0 6 2 name Ljava/lang/String;
0 6 3 ttlSeconds I
0 6 4 daemon Z
MethodParameters:
Name Flags
threadCap
queuedTaskCap
name
ttlSeconds
daemon
public static reactor.core.scheduler.Scheduler newBoundedElastic(int, int, java.util.concurrent.ThreadFactory, int);
descriptor: (IILjava/util/concurrent/ThreadFactory;I)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic reactor.core.scheduler.Schedulers.factory:Lreactor/core/scheduler/Schedulers$Factory;
iload 0
1: iload 1
2: aload 2
3: iload 3
4: invokeinterface reactor.core.scheduler.Schedulers$Factory.newBoundedElastic:(IILjava/util/concurrent/ThreadFactory;I)Lreactor/core/scheduler/Scheduler;
astore 4
start local 4 5: aload 4
invokeinterface reactor.core.scheduler.Scheduler.start:()V
6: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 threadCap I
0 7 1 queuedTaskCap I
0 7 2 threadFactory Ljava/util/concurrent/ThreadFactory;
0 7 3 ttlSeconds I
5 7 4 fromFactory Lreactor/core/scheduler/Scheduler;
MethodParameters:
Name Flags
threadCap
queuedTaskCap
threadFactory
ttlSeconds
public static reactor.core.scheduler.Scheduler newParallel(java.lang.String);
descriptor: (Ljava/lang/String;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getstatic reactor.core.scheduler.Schedulers.DEFAULT_POOL_SIZE:I
invokestatic reactor.core.scheduler.Schedulers.newParallel:(Ljava/lang/String;I)Lreactor/core/scheduler/Scheduler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 name Ljava/lang/String;
MethodParameters:
Name Flags
name
public static reactor.core.scheduler.Scheduler newParallel(java.lang.String, int);
descriptor: (Ljava/lang/String;I)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
iconst_0
invokestatic reactor.core.scheduler.Schedulers.newParallel:(Ljava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 name Ljava/lang/String;
0 1 1 parallelism I
MethodParameters:
Name Flags
name
parallelism
public static reactor.core.scheduler.Scheduler newParallel(java.lang.String, int, boolean);
descriptor: (Ljava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: iload 1
1: new reactor.core.scheduler.ReactorThreadFactory
dup
aload 0
getstatic reactor.core.scheduler.ParallelScheduler.COUNTER:Ljava/util/concurrent/atomic/AtomicLong;
iload 2
2: iconst_1
invokedynamic accept()Ljava/util/function/BiConsumer;
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;Ljava/lang/Object;)V
reactor/core/scheduler/Schedulers.defaultUncaughtException(Ljava/lang/Thread;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Thread;Ljava/lang/Throwable;)V
3: invokespecial reactor.core.scheduler.ReactorThreadFactory.<init>:(Ljava/lang/String;Ljava/util/concurrent/atomic/AtomicLong;ZZLjava/util/function/BiConsumer;)V
4: invokestatic reactor.core.scheduler.Schedulers.newParallel:(ILjava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 name Ljava/lang/String;
0 5 1 parallelism I
0 5 2 daemon Z
MethodParameters:
Name Flags
name
parallelism
daemon
public static reactor.core.scheduler.Scheduler newParallel(int, java.util.concurrent.ThreadFactory);
descriptor: (ILjava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic reactor.core.scheduler.Schedulers.factory:Lreactor/core/scheduler/Schedulers$Factory;
iload 0
aload 1
invokeinterface reactor.core.scheduler.Schedulers$Factory.newParallel:(ILjava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
astore 2
start local 2 1: aload 2
invokeinterface reactor.core.scheduler.Scheduler.start:()V
2: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 parallelism I
0 3 1 threadFactory Ljava/util/concurrent/ThreadFactory;
1 3 2 fromFactory Lreactor/core/scheduler/Scheduler;
MethodParameters:
Name Flags
parallelism
threadFactory
public static reactor.core.scheduler.Scheduler newSingle(java.lang.String);
descriptor: (Ljava/lang/String;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
iconst_0
invokestatic reactor.core.scheduler.Schedulers.newSingle:(Ljava/lang/String;Z)Lreactor/core/scheduler/Scheduler;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 name Ljava/lang/String;
MethodParameters:
Name Flags
name
public static reactor.core.scheduler.Scheduler newSingle(java.lang.String, boolean);
descriptor: (Ljava/lang/String;Z)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: new reactor.core.scheduler.ReactorThreadFactory
dup
aload 0
getstatic reactor.core.scheduler.SingleScheduler.COUNTER:Ljava/util/concurrent/atomic/AtomicLong;
iload 1
1: iconst_1
invokedynamic accept()Ljava/util/function/BiConsumer;
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;Ljava/lang/Object;)V
reactor/core/scheduler/Schedulers.defaultUncaughtException(Ljava/lang/Thread;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Thread;Ljava/lang/Throwable;)V
2: invokespecial reactor.core.scheduler.ReactorThreadFactory.<init>:(Ljava/lang/String;Ljava/util/concurrent/atomic/AtomicLong;ZZLjava/util/function/BiConsumer;)V
invokestatic reactor.core.scheduler.Schedulers.newSingle:(Ljava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 name Ljava/lang/String;
0 3 1 daemon Z
MethodParameters:
Name Flags
name
daemon
public static reactor.core.scheduler.Scheduler newSingle(java.util.concurrent.ThreadFactory);
descriptor: (Ljava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: getstatic reactor.core.scheduler.Schedulers.factory:Lreactor/core/scheduler/Schedulers$Factory;
aload 0
invokeinterface reactor.core.scheduler.Schedulers$Factory.newSingle:(Ljava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
astore 1
start local 1 1: aload 1
invokeinterface reactor.core.scheduler.Scheduler.start:()V
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 threadFactory Ljava/util/concurrent/ThreadFactory;
1 3 1 fromFactory Lreactor/core/scheduler/Scheduler;
MethodParameters:
Name Flags
threadFactory
public static void onHandleError(java.util.function.BiConsumer<java.lang.Thread, ? super java.lang.Throwable>);
descriptor: (Ljava/util/function/BiConsumer;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic reactor.core.scheduler.Schedulers.LOGGER:Lreactor/util/Logger;
invokeinterface reactor.util.Logger.isDebugEnabled:()Z
ifeq 2
1: getstatic reactor.core.scheduler.Schedulers.LOGGER:Lreactor/util/Logger;
ldc "Hooking new default: onHandleError"
invokeinterface reactor.util.Logger.debug:(Ljava/lang/String;)V
2: StackMap locals:
StackMap stack:
aload 0
ldc "onHandleError"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
checkcast java.util.function.BiConsumer
putstatic reactor.core.scheduler.Schedulers.onHandleErrorHook:Ljava/util/function/BiConsumer;
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 c Ljava/util/function/BiConsumer<Ljava/lang/Thread;-Ljava/lang/Throwable;>;
Signature: (Ljava/util/function/BiConsumer<Ljava/lang/Thread;-Ljava/lang/Throwable;>;)V
MethodParameters:
Name Flags
c
public static boolean isInNonBlockingThread();
descriptor: ()Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
instanceof reactor.core.scheduler.NonBlocking
ireturn
LocalVariableTable:
Start End Slot Name Signature
public static boolean isNonBlockingThread(java.lang.Thread);
descriptor: (Ljava/lang/Thread;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
instanceof reactor.core.scheduler.NonBlocking
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 t Ljava/lang/Thread;
MethodParameters:
Name Flags
t
public static void enableMetrics();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: invokestatic reactor.util.Metrics.isInstrumentationAvailable:()Z
ifeq 2
1: ldc "reactor.metrics.decorator"
new reactor.core.scheduler.SchedulerMetricDecorator
dup
invokespecial reactor.core.scheduler.SchedulerMetricDecorator.<init>:()V
invokestatic reactor.core.scheduler.Schedulers.addExecutorServiceDecorator:(Ljava/lang/String;Ljava/util/function/BiFunction;)Z
pop
2: StackMap locals:
StackMap stack:
return
LocalVariableTable:
Start End Slot Name Signature
public static void disableMetrics();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc "reactor.metrics.decorator"
invokestatic reactor.core.scheduler.Schedulers.removeExecutorServiceDecorator:(Ljava/lang/String;)Ljava/util/function/BiFunction;
pop
1: return
LocalVariableTable:
Start End Slot Name Signature
public static void resetFactory();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.DEFAULT:Lreactor/core/scheduler/Schedulers$Factory;
invokestatic reactor.core.scheduler.Schedulers.setFactory:(Lreactor/core/scheduler/Schedulers$Factory;)V
1: return
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.scheduler.Schedulers$Snapshot setFactoryWithSnapshot(reactor.core.scheduler.Schedulers$Factory);
descriptor: (Lreactor/core/scheduler/Schedulers$Factory;)Lreactor/core/scheduler/Schedulers$Snapshot;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=2, args_size=1
start local 0 0: new reactor.core.scheduler.Schedulers$Snapshot
dup
1: getstatic reactor.core.scheduler.Schedulers.CACHED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
2: getstatic reactor.core.scheduler.Schedulers.CACHED_BOUNDED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
3: getstatic reactor.core.scheduler.Schedulers.CACHED_PARALLEL:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
4: getstatic reactor.core.scheduler.Schedulers.CACHED_SINGLE:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
5: getstatic reactor.core.scheduler.Schedulers.factory:Lreactor/core/scheduler/Schedulers$Factory;
6: invokespecial reactor.core.scheduler.Schedulers$Snapshot.<init>:(Lreactor/core/scheduler/Schedulers$CachedScheduler;Lreactor/core/scheduler/Schedulers$CachedScheduler;Lreactor/core/scheduler/Schedulers$CachedScheduler;Lreactor/core/scheduler/Schedulers$CachedScheduler;Lreactor/core/scheduler/Schedulers$Factory;)V
astore 1
start local 1 7: aload 0
invokestatic reactor.core.scheduler.Schedulers.setFactory:(Lreactor/core/scheduler/Schedulers$Factory;)V
8: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 newFactory Lreactor/core/scheduler/Schedulers$Factory;
7 9 1 snapshot Lreactor/core/scheduler/Schedulers$Snapshot;
MethodParameters:
Name Flags
newFactory
public static void resetFrom(reactor.core.scheduler.Schedulers$Snapshot);
descriptor: (Lreactor/core/scheduler/Schedulers$Snapshot;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=5, args_size=1
start local 0 0: aload 0
ifnonnull 3
1: invokestatic reactor.core.scheduler.Schedulers.resetFactory:()V
2: return
3: StackMap locals:
StackMap stack:
getstatic reactor.core.scheduler.Schedulers.CACHED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
aload 0
getfield reactor.core.scheduler.Schedulers$Snapshot.oldElasticScheduler:Lreactor/core/scheduler/Schedulers$CachedScheduler;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 1
start local 1 4: getstatic reactor.core.scheduler.Schedulers.CACHED_BOUNDED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
aload 0
getfield reactor.core.scheduler.Schedulers$Snapshot.oldBoundedElasticScheduler:Lreactor/core/scheduler/Schedulers$CachedScheduler;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 2
start local 2 5: getstatic reactor.core.scheduler.Schedulers.CACHED_PARALLEL:Ljava/util/concurrent/atomic/AtomicReference;
aload 0
getfield reactor.core.scheduler.Schedulers$Snapshot.oldParallelScheduler:Lreactor/core/scheduler/Schedulers$CachedScheduler;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 3
start local 3 6: getstatic reactor.core.scheduler.Schedulers.CACHED_SINGLE:Ljava/util/concurrent/atomic/AtomicReference;
aload 0
getfield reactor.core.scheduler.Schedulers$Snapshot.oldSingleScheduler:Lreactor/core/scheduler/Schedulers$CachedScheduler;
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 4
start local 4 7: aload 0
getfield reactor.core.scheduler.Schedulers$Snapshot.oldFactory:Lreactor/core/scheduler/Schedulers$Factory;
putstatic reactor.core.scheduler.Schedulers.factory:Lreactor/core/scheduler/Schedulers$Factory;
8: aload 1
ifnull 9
aload 1
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
9: StackMap locals: reactor.core.scheduler.Schedulers$Snapshot reactor.core.scheduler.Schedulers$CachedScheduler reactor.core.scheduler.Schedulers$CachedScheduler reactor.core.scheduler.Schedulers$CachedScheduler reactor.core.scheduler.Schedulers$CachedScheduler
StackMap stack:
aload 2
ifnull 10
aload 2
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
10: StackMap locals:
StackMap stack:
aload 3
ifnull 11
aload 3
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
11: StackMap locals:
StackMap stack:
aload 4
ifnull 12
aload 4
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
12: StackMap locals:
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 snapshot Lreactor/core/scheduler/Schedulers$Snapshot;
4 13 1 oldElastic Lreactor/core/scheduler/Schedulers$CachedScheduler;
5 13 2 oldBoundedElastic Lreactor/core/scheduler/Schedulers$CachedScheduler;
6 13 3 oldParallel Lreactor/core/scheduler/Schedulers$CachedScheduler;
7 13 4 oldSingle Lreactor/core/scheduler/Schedulers$CachedScheduler;
RuntimeVisibleParameterAnnotations:
0:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
snapshot
public static void resetOnHandleError();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.LOGGER:Lreactor/util/Logger;
invokeinterface reactor.util.Logger.isDebugEnabled:()Z
ifeq 2
1: getstatic reactor.core.scheduler.Schedulers.LOGGER:Lreactor/util/Logger;
ldc "Reset to factory defaults: onHandleError"
invokeinterface reactor.util.Logger.debug:(Ljava/lang/String;)V
2: StackMap locals:
StackMap stack:
aconst_null
putstatic reactor.core.scheduler.Schedulers.onHandleErrorHook:Ljava/util/function/BiConsumer;
3: return
LocalVariableTable:
Start End Slot Name Signature
public static void setFactory(reactor.core.scheduler.Schedulers$Factory);
descriptor: (Lreactor/core/scheduler/Schedulers$Factory;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
ldc "factoryInstance"
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;Ljava/lang/String;)Ljava/lang/Object;
pop
1: invokestatic reactor.core.scheduler.Schedulers.shutdownNow:()V
2: aload 0
putstatic reactor.core.scheduler.Schedulers.factory:Lreactor/core/scheduler/Schedulers$Factory;
3: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 factoryInstance Lreactor/core/scheduler/Schedulers$Factory;
MethodParameters:
Name Flags
factoryInstance
public static boolean addExecutorServiceDecorator(java.lang.String, java.util.function.BiFunction<reactor.core.scheduler.Scheduler, java.util.concurrent.ScheduledExecutorService, java.util.concurrent.ScheduledExecutorService>);
descriptor: (Ljava/lang/String;Ljava/util/function/BiFunction;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
dup
astore 2
monitorenter
1: getstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
aload 0
aload 1
invokeinterface java.util.Map.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
ifnonnull 2
iconst_1
goto 3
StackMap locals: java.util.Map
StackMap stack:
2: iconst_0
StackMap locals:
StackMap stack: int
3: aload 2
monitorexit
4: ireturn
5: StackMap locals:
StackMap stack: java.lang.Throwable
aload 2
monitorexit
6: athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 key Ljava/lang/String;
0 7 1 decorator Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;
Exception table:
from to target type
1 4 5 any
5 6 5 any
Signature: (Ljava/lang/String;Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;)Z
MethodParameters:
Name Flags
key
decorator
public static void setExecutorServiceDecorator(java.lang.String, java.util.function.BiFunction<reactor.core.scheduler.Scheduler, java.util.concurrent.ScheduledExecutorService, java.util.concurrent.ScheduledExecutorService>);
descriptor: (Ljava/lang/String;Ljava/util/function/BiFunction;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: getstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
dup
astore 2
monitorenter
1: getstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
aload 0
aload 1
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 2
monitorexit
3: goto 6
StackMap locals: java.lang.String java.util.function.BiFunction java.util.Map
StackMap stack: java.lang.Throwable
4: aload 2
monitorexit
5: athrow
6: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 key Ljava/lang/String;
0 7 1 decorator Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
Signature: (Ljava/lang/String;Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;)V
MethodParameters:
Name Flags
key
decorator
public static java.util.function.BiFunction<reactor.core.scheduler.Scheduler, java.util.concurrent.ScheduledExecutorService, java.util.concurrent.ScheduledExecutorService> removeExecutorServiceDecorator(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/function/BiFunction;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: getstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
dup
astore 2
monitorenter
1: getstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
aload 0
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.function.BiFunction
astore 1
start local 1 2: aload 2
monitorexit
3: goto 6
end local 1 StackMap locals: java.lang.String top java.util.Map
StackMap stack: java.lang.Throwable
4: aload 2
monitorexit
5: athrow
start local 1 6: StackMap locals: java.lang.String java.util.function.BiFunction
StackMap stack:
aload 1
instanceof reactor.core.Disposable
ifeq 8
7: aload 1
checkcast reactor.core.Disposable
invokeinterface reactor.core.Disposable.dispose:()V
8: StackMap locals:
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 key Ljava/lang/String;
2 4 1 removed Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;
6 9 1 removed Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;
Exception table:
from to target type
1 3 4 any
4 5 4 any
Signature: (Ljava/lang/String;)Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;
MethodParameters:
Name Flags
key
public static java.util.concurrent.ScheduledExecutorService decorateExecutorService(reactor.core.scheduler.Scheduler, java.util.concurrent.ScheduledExecutorService);
descriptor: (Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;)Ljava/util/concurrent/ScheduledExecutorService;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: getstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
dup
astore 2
monitorenter
1: getstatic reactor.core.scheduler.Schedulers.DECORATORS:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: reactor.core.scheduler.Scheduler java.util.concurrent.ScheduledExecutorService java.util.Map top java.util.Iterator
StackMap stack:
2: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.function.BiFunction
astore 3
start local 3 3: aload 3
aload 0
aload 1
invokeinterface java.util.function.BiFunction.apply:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.concurrent.ScheduledExecutorService
astore 1
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
5: aload 2
monitorexit
6: goto 9
StackMap locals: reactor.core.scheduler.Scheduler java.util.concurrent.ScheduledExecutorService java.util.Map
StackMap stack: java.lang.Throwable
7: aload 2
monitorexit
8: athrow
9: StackMap locals:
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 owner Lreactor/core/scheduler/Scheduler;
0 10 1 original Ljava/util/concurrent/ScheduledExecutorService;
3 4 3 decorator Ljava/util/function/BiFunction<Lreactor/core/scheduler/Scheduler;Ljava/util/concurrent/ScheduledExecutorService;Ljava/util/concurrent/ScheduledExecutorService;>;
Exception table:
from to target type
1 6 7 any
7 8 7 any
MethodParameters:
Name Flags
owner
original
public static void onScheduleHook(java.lang.String, java.util.function.Function<java.lang.Runnable, java.lang.Runnable>);
descriptor: (Ljava/lang/String;Ljava/util/function/Function;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
dup
astore 2
monitorenter
1: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
aload 0
aload 1
invokevirtual java.util.LinkedHashMap.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aconst_null
astore 3
start local 3 3: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
invokevirtual java.util.LinkedHashMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 5
goto 9
StackMap locals: java.lang.String java.util.function.Function java.util.LinkedHashMap java.util.function.Function top java.util.Iterator
StackMap stack:
4: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.function.Function
astore 4
start local 4 5: aload 3
ifnonnull 8
6: aload 4
astore 3
7: goto 9
8: StackMap locals: java.lang.String java.util.function.Function java.util.LinkedHashMap java.util.function.Function java.util.function.Function java.util.Iterator
StackMap stack:
aload 3
aload 4
invokeinterface java.util.function.Function.andThen:(Ljava/util/function/Function;)Ljava/util/function/Function;
astore 3
end local 4 9: StackMap locals: java.lang.String java.util.function.Function java.util.LinkedHashMap java.util.function.Function top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
10: aload 3
putstatic reactor.core.scheduler.Schedulers.onScheduleHook:Ljava/util/function/Function;
end local 3 11: aload 2
monitorexit
12: goto 15
StackMap locals: java.lang.String java.util.function.Function java.util.LinkedHashMap
StackMap stack: java.lang.Throwable
13: aload 2
monitorexit
14: athrow
15: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 key Ljava/lang/String;
0 16 1 decorator Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;
3 11 3 newHook Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;
5 9 4 function Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;
Exception table:
from to target type
1 12 13 any
13 14 13 any
Signature: (Ljava/lang/String;Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;)V
MethodParameters:
Name Flags
key
decorator
public static void resetOnScheduleHook(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=5, args_size=1
start local 0 0: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
dup
astore 1
monitorenter
1: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
aload 0
invokevirtual java.util.LinkedHashMap.remove:(Ljava/lang/Object;)Ljava/lang/Object;
pop
2: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
invokevirtual java.util.LinkedHashMap.isEmpty:()Z
ifeq 5
3: invokestatic java.util.function.Function.identity:()Ljava/util/function/Function;
putstatic reactor.core.scheduler.Schedulers.onScheduleHook:Ljava/util/function/Function;
4: goto 14
5: StackMap locals: java.util.LinkedHashMap
StackMap stack:
aconst_null
astore 2
start local 2 6: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
invokevirtual java.util.LinkedHashMap.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 12
StackMap locals: java.lang.String java.util.LinkedHashMap java.util.function.Function top java.util.Iterator
StackMap stack:
7: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.function.Function
astore 3
start local 3 8: aload 2
ifnonnull 11
9: aload 3
astore 2
10: goto 12
11: StackMap locals: java.lang.String java.util.LinkedHashMap java.util.function.Function java.util.function.Function java.util.Iterator
StackMap stack:
aload 2
aload 3
invokeinterface java.util.function.Function.andThen:(Ljava/util/function/Function;)Ljava/util/function/Function;
astore 2
end local 3 12: StackMap locals: java.lang.String java.util.LinkedHashMap java.util.function.Function top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
13: aload 2
putstatic reactor.core.scheduler.Schedulers.onScheduleHook:Ljava/util/function/Function;
end local 2 14: StackMap locals: java.lang.String java.util.LinkedHashMap
StackMap stack:
aload 1
monitorexit
15: goto 18
StackMap locals:
StackMap stack: java.lang.Throwable
16: aload 1
monitorexit
17: athrow
18: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 key Ljava/lang/String;
6 14 2 newHook Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;
8 12 3 function Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;
Exception table:
from to target type
1 15 16 any
16 17 16 any
MethodParameters:
Name Flags
key
public static void resetOnScheduleHooks();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
dup
astore 0
monitorenter
1: getstatic reactor.core.scheduler.Schedulers.onScheduleHooks:Ljava/util/LinkedHashMap;
invokevirtual java.util.LinkedHashMap.clear:()V
2: aconst_null
putstatic reactor.core.scheduler.Schedulers.onScheduleHook:Ljava/util/function/Function;
3: aload 0
monitorexit
4: goto 7
StackMap locals: java.util.LinkedHashMap
StackMap stack: java.lang.Throwable
5: aload 0
monitorexit
6: athrow
7: StackMap locals:
StackMap stack:
return
LocalVariableTable:
Start End Slot Name Signature
Exception table:
from to target type
1 4 5 any
5 6 5 any
public static java.lang.Runnable onSchedule(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)Ljava/lang/Runnable;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: getstatic reactor.core.scheduler.Schedulers.onScheduleHook:Ljava/util/function/Function;
astore 1
start local 1 1: aload 1
ifnull 3
2: aload 1
aload 0
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.Runnable
areturn
3: StackMap locals: java.util.function.Function
StackMap stack:
aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 runnable Ljava/lang/Runnable;
1 4 1 hook Ljava/util/function/Function<Ljava/lang/Runnable;Ljava/lang/Runnable;>;
MethodParameters:
Name Flags
runnable
public static void shutdownNow();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=4, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.CACHED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 0
start local 0 1: getstatic reactor.core.scheduler.Schedulers.CACHED_BOUNDED_ELASTIC:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 1
start local 1 2: getstatic reactor.core.scheduler.Schedulers.CACHED_PARALLEL:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 2
start local 2 3: getstatic reactor.core.scheduler.Schedulers.CACHED_SINGLE:Ljava/util/concurrent/atomic/AtomicReference;
aconst_null
invokevirtual java.util.concurrent.atomic.AtomicReference.getAndSet:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 3
start local 3 4: aload 0
ifnull 5
aload 0
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
5: StackMap locals: reactor.core.scheduler.Schedulers$CachedScheduler reactor.core.scheduler.Schedulers$CachedScheduler reactor.core.scheduler.Schedulers$CachedScheduler reactor.core.scheduler.Schedulers$CachedScheduler
StackMap stack:
aload 1
ifnull 6
aload 1
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
6: StackMap locals:
StackMap stack:
aload 2
ifnull 7
aload 2
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
7: StackMap locals:
StackMap stack:
aload 3
ifnull 8
aload 3
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
8: StackMap locals:
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 9 0 oldElastic Lreactor/core/scheduler/Schedulers$CachedScheduler;
2 9 1 oldBoundedElastic Lreactor/core/scheduler/Schedulers$CachedScheduler;
3 9 2 oldParallel Lreactor/core/scheduler/Schedulers$CachedScheduler;
4 9 3 oldSingle Lreactor/core/scheduler/Schedulers$CachedScheduler;
public static reactor.core.scheduler.Scheduler single();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=0, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.CACHED_SINGLE:Ljava/util/concurrent/atomic/AtomicReference;
ldc "single"
getstatic reactor.core.scheduler.Schedulers.SINGLE_SUPPLIER:Ljava/util/function/Supplier;
invokestatic reactor.core.scheduler.Schedulers.cache:(Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/String;Ljava/util/function/Supplier;)Lreactor/core/scheduler/Schedulers$CachedScheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
public static reactor.core.scheduler.Scheduler single(reactor.core.scheduler.Scheduler);
descriptor: (Lreactor/core/scheduler/Scheduler;)Lreactor/core/scheduler/Scheduler;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new reactor.core.scheduler.SingleWorkerScheduler
dup
aload 0
invokespecial reactor.core.scheduler.SingleWorkerScheduler.<init>:(Lreactor/core/scheduler/Scheduler;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 original Lreactor/core/scheduler/Scheduler;
MethodParameters:
Name Flags
original
static reactor.core.scheduler.Schedulers$CachedScheduler cache(java.util.concurrent.atomic.AtomicReference<reactor.core.scheduler.Schedulers$CachedScheduler>, java.lang.String, java.util.function.Supplier<reactor.core.scheduler.Scheduler>);
descriptor: (Ljava/util/concurrent/atomic/AtomicReference;Ljava/lang/String;Ljava/util/function/Supplier;)Lreactor/core/scheduler/Schedulers$CachedScheduler;
flags: (0x0008) ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
astore 3
start local 3 1: aload 3
ifnull 3
2: aload 3
areturn
3: StackMap locals: reactor.core.scheduler.Schedulers$CachedScheduler
StackMap stack:
new reactor.core.scheduler.Schedulers$CachedScheduler
dup
aload 1
aload 2
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
checkcast reactor.core.scheduler.Scheduler
invokespecial reactor.core.scheduler.Schedulers$CachedScheduler.<init>:(Ljava/lang/String;Lreactor/core/scheduler/Scheduler;)V
astore 3
4: aload 0
aconst_null
aload 3
invokevirtual java.util.concurrent.atomic.AtomicReference.compareAndSet:(Ljava/lang/Object;Ljava/lang/Object;)Z
ifeq 6
5: aload 3
areturn
6: StackMap locals:
StackMap stack:
aload 3
invokevirtual reactor.core.scheduler.Schedulers$CachedScheduler._dispose:()V
7: aload 0
invokevirtual java.util.concurrent.atomic.AtomicReference.get:()Ljava/lang/Object;
checkcast reactor.core.scheduler.Schedulers$CachedScheduler
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 reference Ljava/util/concurrent/atomic/AtomicReference<Lreactor/core/scheduler/Schedulers$CachedScheduler;>;
0 8 1 key Ljava/lang/String;
0 8 2 supplier Ljava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;
1 8 3 s Lreactor/core/scheduler/Schedulers$CachedScheduler;
Signature: (Ljava/util/concurrent/atomic/AtomicReference<Lreactor/core/scheduler/Schedulers$CachedScheduler;>;Ljava/lang/String;Ljava/util/function/Supplier<Lreactor/core/scheduler/Scheduler;>;)Lreactor/core/scheduler/Schedulers$CachedScheduler;
MethodParameters:
Name Flags
reference
key
supplier
static final void defaultUncaughtException(java.lang.Thread, java.lang.Throwable);
descriptor: (Ljava/lang/Thread;Ljava/lang/Throwable;)V
flags: (0x0018) ACC_STATIC, ACC_FINAL
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic reactor.core.scheduler.Schedulers.LOGGER:Lreactor/util/Logger;
new java.lang.StringBuilder
dup
ldc "Scheduler worker in group "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual java.lang.Thread.getThreadGroup:()Ljava/lang/ThreadGroup;
invokevirtual java.lang.ThreadGroup.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
1: ldc " failed with an uncaught exception"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 1
2: invokeinterface reactor.util.Logger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 t Ljava/lang/Thread;
0 4 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
t
e
static void handleError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=5, args_size=1
start local 0 0: invokestatic java.lang.Thread.currentThread:()Ljava/lang/Thread;
astore 1
start local 1 1: aload 0
invokestatic reactor.core.Exceptions.unwrap:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
astore 2
start local 2 2: aload 1
invokevirtual java.lang.Thread.getUncaughtExceptionHandler:()Ljava/lang/Thread$UncaughtExceptionHandler;
astore 3
start local 3 3: aload 3
ifnull 6
4: aload 3
aload 1
aload 2
invokeinterface java.lang.Thread$UncaughtExceptionHandler.uncaughtException:(Ljava/lang/Thread;Ljava/lang/Throwable;)V
5: goto 7
6: StackMap locals: java.lang.Thread java.lang.Throwable java.lang.Thread$UncaughtExceptionHandler
StackMap stack:
getstatic reactor.core.scheduler.Schedulers.LOGGER:Lreactor/util/Logger;
ldc "Scheduler worker failed with an uncaught exception"
aload 2
invokeinterface reactor.util.Logger.error:(Ljava/lang/String;Ljava/lang/Throwable;)V
7: StackMap locals:
StackMap stack:
getstatic reactor.core.scheduler.Schedulers.onHandleErrorHook:Ljava/util/function/BiConsumer;
astore 4
start local 4 8: aload 4
ifnull 10
9: aload 4
aload 1
aload 2
invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
10: StackMap locals: java.util.function.BiConsumer
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 ex Ljava/lang/Throwable;
1 11 1 thread Ljava/lang/Thread;
2 11 2 t Ljava/lang/Throwable;
3 11 3 x Ljava/lang/Thread$UncaughtExceptionHandler;
8 11 4 hook Ljava/util/function/BiConsumer<Ljava/lang/Thread;-Ljava/lang/Throwable;>;
MethodParameters:
Name Flags
ex
static reactor.core.Disposable directSchedule(java.util.concurrent.ScheduledExecutorService, java.lang.Runnable, reactor.core.Disposable, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/ScheduledExecutorService;Ljava/lang/Runnable;Lreactor/core/Disposable;JLjava/util/concurrent/TimeUnit;)Lreactor/core/Disposable;
flags: (0x0008) ACC_STATIC
Code:
stack=5, locals=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 1
invokestatic reactor.core.scheduler.Schedulers.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
astore 1
1: new reactor.core.scheduler.SchedulerTask
dup
aload 1
aload 2
invokespecial reactor.core.scheduler.SchedulerTask.<init>:(Ljava/lang/Runnable;Lreactor/core/Disposable;)V
astore 6
start local 6 2: lload 3
lconst_0
lcmp
ifgt 5
3: aload 0
aload 6
invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
astore 7
start local 7 4: goto 6
end local 7 5: StackMap locals: reactor.core.scheduler.SchedulerTask
StackMap stack:
aload 0
aload 6
lload 3
aload 5
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 7
start local 7 6: StackMap locals: java.util.concurrent.Future
StackMap stack:
aload 6
aload 7
invokevirtual reactor.core.scheduler.SchedulerTask.setFuture:(Ljava/util/concurrent/Future;)V
7: aload 6
areturn
end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 exec Ljava/util/concurrent/ScheduledExecutorService;
0 8 1 task Ljava/lang/Runnable;
0 8 2 parent Lreactor/core/Disposable;
0 8 3 delay J
0 8 5 unit Ljava/util/concurrent/TimeUnit;
2 8 6 sr Lreactor/core/scheduler/SchedulerTask;
4 5 7 f Ljava/util/concurrent/Future<*>;
6 8 7 f Ljava/util/concurrent/Future<*>;
RuntimeVisibleParameterAnnotations:
0:
1:
2:
reactor.util.annotation.Nullable()
3:
4:
MethodParameters:
Name Flags
exec
task
parent
delay
unit
static reactor.core.Disposable directSchedulePeriodically(java.util.concurrent.ScheduledExecutorService, java.lang.Runnable, long, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/ScheduledExecutorService;Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lreactor/core/Disposable;
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=9, args_size=5
start local 0 start local 1 start local 2 start local 4 start local 6 0: aload 1
invokestatic reactor.core.scheduler.Schedulers.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
astore 1
1: lload 4
lconst_0
lcmp
ifgt 10
2: new reactor.core.scheduler.InstantPeriodicWorkerTask
dup
aload 1
aload 0
invokespecial reactor.core.scheduler.InstantPeriodicWorkerTask.<init>:(Ljava/lang/Runnable;Ljava/util/concurrent/ExecutorService;)V
3: astore 7
start local 7 4: lload 2
lconst_0
lcmp
ifgt 7
5: aload 0
aload 7
invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
astore 8
start local 8 6: goto 8
end local 8 7: StackMap locals: reactor.core.scheduler.InstantPeriodicWorkerTask
StackMap stack:
aload 0
aload 7
lload 2
aload 6
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 8
start local 8 8: StackMap locals: java.util.concurrent.Future
StackMap stack:
aload 7
aload 8
invokevirtual reactor.core.scheduler.InstantPeriodicWorkerTask.setFirst:(Ljava/util/concurrent/Future;)V
9: aload 7
areturn
end local 8 end local 7 10: StackMap locals:
StackMap stack:
new reactor.core.scheduler.PeriodicSchedulerTask
dup
aload 1
invokespecial reactor.core.scheduler.PeriodicSchedulerTask.<init>:(Ljava/lang/Runnable;)V
astore 7
start local 7 11: aload 0
aload 7
lload 2
lload 4
aload 6
invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 8
start local 8 12: aload 7
aload 8
invokevirtual reactor.core.scheduler.PeriodicSchedulerTask.setFuture:(Ljava/util/concurrent/Future;)V
13: aload 7
areturn
end local 8 end local 7 end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 exec Ljava/util/concurrent/ScheduledExecutorService;
0 14 1 task Ljava/lang/Runnable;
0 14 2 initialDelay J
0 14 4 period J
0 14 6 unit Ljava/util/concurrent/TimeUnit;
4 10 7 isr Lreactor/core/scheduler/InstantPeriodicWorkerTask;
6 7 8 f Ljava/util/concurrent/Future<*>;
8 10 8 f Ljava/util/concurrent/Future<*>;
11 14 7 sr Lreactor/core/scheduler/PeriodicSchedulerTask;
12 14 8 f Ljava/util/concurrent/Future<*>;
MethodParameters:
Name Flags
exec
task
initialDelay
period
unit
static reactor.core.Disposable workerSchedule(java.util.concurrent.ScheduledExecutorService, reactor.core.Disposable$Composite, java.lang.Runnable, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/ScheduledExecutorService;Lreactor/core/Disposable$Composite;Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lreactor/core/Disposable;
flags: (0x0008) ACC_STATIC
Code:
stack=5, locals=8, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 5 0: aload 2
invokestatic reactor.core.scheduler.Schedulers.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
astore 2
1: new reactor.core.scheduler.WorkerTask
dup
aload 2
aload 1
invokespecial reactor.core.scheduler.WorkerTask.<init>:(Ljava/lang/Runnable;Lreactor/core/Disposable$Composite;)V
astore 6
start local 6 2: aload 1
aload 6
invokeinterface reactor.core.Disposable$Composite.add:(Lreactor/core/Disposable;)Z
ifne 4
3: invokestatic reactor.core.Exceptions.failWithRejected:()Ljava/util/concurrent/RejectedExecutionException;
athrow
4: StackMap locals: reactor.core.scheduler.WorkerTask
StackMap stack:
lload 3
lconst_0
lcmp
ifgt 7
5: aload 0
aload 6
invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
astore 7
start local 7 6: goto 8
end local 7 7: StackMap locals:
StackMap stack:
aload 0
aload 6
lload 3
aload 5
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 7
start local 7 8: StackMap locals: java.util.concurrent.Future
StackMap stack:
aload 6
aload 7
invokevirtual reactor.core.scheduler.WorkerTask.setFuture:(Ljava/util/concurrent/Future;)V
end local 7 9: goto 13
10: StackMap locals: java.util.concurrent.ScheduledExecutorService reactor.core.Disposable$Composite java.lang.Runnable long java.util.concurrent.TimeUnit reactor.core.scheduler.WorkerTask
StackMap stack: java.util.concurrent.RejectedExecutionException
astore 7
start local 7 11: aload 6
invokevirtual reactor.core.scheduler.WorkerTask.dispose:()V
12: aload 7
athrow
end local 7 13: StackMap locals:
StackMap stack:
aload 6
areturn
end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 exec Ljava/util/concurrent/ScheduledExecutorService;
0 14 1 tasks Lreactor/core/Disposable$Composite;
0 14 2 task Ljava/lang/Runnable;
0 14 3 delay J
0 14 5 unit Ljava/util/concurrent/TimeUnit;
2 14 6 sr Lreactor/core/scheduler/WorkerTask;
6 7 7 f Ljava/util/concurrent/Future<*>;
8 9 7 f Ljava/util/concurrent/Future<*>;
11 13 7 ex Ljava/util/concurrent/RejectedExecutionException;
Exception table:
from to target type
4 9 10 Class java.util.concurrent.RejectedExecutionException
MethodParameters:
Name Flags
exec
tasks
task
delay
unit
static reactor.core.Disposable workerSchedulePeriodically(java.util.concurrent.ScheduledExecutorService, reactor.core.Disposable$Composite, java.lang.Runnable, long, long, java.util.concurrent.TimeUnit);
descriptor: (Ljava/util/concurrent/ScheduledExecutorService;Lreactor/core/Disposable$Composite;Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lreactor/core/Disposable;
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=10, args_size=6
start local 0 start local 1 start local 2 start local 3 start local 5 start local 7 0: aload 2
invokestatic reactor.core.scheduler.Schedulers.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
astore 2
1: lload 5
lconst_0
lcmp
ifgt 19
2: new reactor.core.scheduler.InstantPeriodicWorkerTask
dup
aload 2
aload 0
aload 1
invokespecial reactor.core.scheduler.InstantPeriodicWorkerTask.<init>:(Ljava/lang/Runnable;Ljava/util/concurrent/ExecutorService;Lreactor/core/Disposable$Composite;)V
3: astore 8
start local 8 4: aload 1
aload 8
invokeinterface reactor.core.Disposable$Composite.add:(Lreactor/core/Disposable;)Z
ifne 6
5: invokestatic reactor.core.Exceptions.failWithRejected:()Ljava/util/concurrent/RejectedExecutionException;
athrow
6: StackMap locals: reactor.core.scheduler.InstantPeriodicWorkerTask
StackMap stack:
lload 3
lconst_0
lcmp
ifgt 9
7: aload 0
aload 8
invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
astore 9
start local 9 8: goto 10
end local 9 9: StackMap locals:
StackMap stack:
aload 0
aload 8
lload 3
aload 7
invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 9
start local 9 10: StackMap locals: java.util.concurrent.Future
StackMap stack:
aload 8
aload 9
invokevirtual reactor.core.scheduler.InstantPeriodicWorkerTask.setFirst:(Ljava/util/concurrent/Future;)V
end local 9 11: goto 18
12: StackMap locals: java.util.concurrent.ScheduledExecutorService reactor.core.Disposable$Composite java.lang.Runnable long long java.util.concurrent.TimeUnit reactor.core.scheduler.InstantPeriodicWorkerTask
StackMap stack: java.util.concurrent.RejectedExecutionException
astore 9
start local 9 13: aload 8
invokevirtual reactor.core.scheduler.InstantPeriodicWorkerTask.dispose:()V
14: aload 9
athrow
end local 9 15: StackMap locals:
StackMap stack: java.lang.RuntimeException
astore 9
start local 9 16: aload 8
invokevirtual reactor.core.scheduler.InstantPeriodicWorkerTask.dispose:()V
17: new java.util.concurrent.RejectedExecutionException
dup
aload 9
invokespecial java.util.concurrent.RejectedExecutionException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 9 18: StackMap locals:
StackMap stack:
aload 8
areturn
end local 8 19: StackMap locals:
StackMap stack:
new reactor.core.scheduler.PeriodicWorkerTask
dup
aload 2
aload 1
invokespecial reactor.core.scheduler.PeriodicWorkerTask.<init>:(Ljava/lang/Runnable;Lreactor/core/Disposable$Composite;)V
astore 8
start local 8 20: aload 1
aload 8
invokeinterface reactor.core.Disposable$Composite.add:(Lreactor/core/Disposable;)Z
ifne 22
21: invokestatic reactor.core.Exceptions.failWithRejected:()Ljava/util/concurrent/RejectedExecutionException;
athrow
22: StackMap locals: reactor.core.scheduler.PeriodicWorkerTask
StackMap stack:
aload 0
aload 8
lload 3
lload 5
aload 7
invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
astore 9
start local 9 23: aload 8
aload 9
invokevirtual reactor.core.scheduler.PeriodicWorkerTask.setFuture:(Ljava/util/concurrent/Future;)V
end local 9 24: goto 31
25: StackMap locals:
StackMap stack: java.util.concurrent.RejectedExecutionException
astore 9
start local 9 26: aload 8
invokevirtual reactor.core.scheduler.PeriodicWorkerTask.dispose:()V
27: aload 9
athrow
end local 9 28: StackMap locals:
StackMap stack: java.lang.RuntimeException
astore 9
start local 9 29: aload 8
invokevirtual reactor.core.scheduler.PeriodicWorkerTask.dispose:()V
30: new java.util.concurrent.RejectedExecutionException
dup
aload 9
invokespecial java.util.concurrent.RejectedExecutionException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 9 31: StackMap locals:
StackMap stack:
aload 8
areturn
end local 8 end local 7 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 32 0 exec Ljava/util/concurrent/ScheduledExecutorService;
0 32 1 tasks Lreactor/core/Disposable$Composite;
0 32 2 task Ljava/lang/Runnable;
0 32 3 initialDelay J
0 32 5 period J
0 32 7 unit Ljava/util/concurrent/TimeUnit;
4 19 8 isr Lreactor/core/scheduler/InstantPeriodicWorkerTask;
8 9 9 f Ljava/util/concurrent/Future<*>;
10 11 9 f Ljava/util/concurrent/Future<*>;
13 15 9 ex Ljava/util/concurrent/RejectedExecutionException;
16 18 9 ex Ljava/lang/RuntimeException;
20 32 8 sr Lreactor/core/scheduler/PeriodicWorkerTask;
23 24 9 f Ljava/util/concurrent/Future<*>;
26 28 9 ex Ljava/util/concurrent/RejectedExecutionException;
29 31 9 ex Ljava/lang/RuntimeException;
Exception table:
from to target type
6 11 12 Class java.util.concurrent.RejectedExecutionException
6 11 15 Class java.lang.IllegalArgumentException
6 11 15 Class java.lang.NullPointerException
22 24 25 Class java.util.concurrent.RejectedExecutionException
22 24 28 Class java.lang.IllegalArgumentException
22 24 28 Class java.lang.NullPointerException
MethodParameters:
Name Flags
exec
tasks
task
initialDelay
period
unit
static final java.lang.Object scanExecutor(java.util.concurrent.Executor, reactor.core.Scannable$Attr);
descriptor: (Ljava/util/concurrent/Executor;Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
instanceof reactor.core.scheduler.DelegateServiceScheduler$UnsupportedScheduledExecutorService
ifeq 2
1: aload 0
checkcast reactor.core.scheduler.DelegateServiceScheduler$UnsupportedScheduledExecutorService
invokevirtual reactor.core.scheduler.DelegateServiceScheduler$UnsupportedScheduledExecutorService.get:()Ljava/util/concurrent/ExecutorService;
astore 0
2: StackMap locals:
StackMap stack:
aload 0
instanceof reactor.core.Scannable
ifeq 4
3: aload 0
checkcast reactor.core.Scannable
aload 1
invokeinterface reactor.core.Scannable.scanUnsafe:(Lreactor/core/Scannable$Attr;)Ljava/lang/Object;
areturn
4: StackMap locals:
StackMap stack:
aload 0
instanceof java.util.concurrent.ExecutorService
ifeq 8
5: aload 0
checkcast java.util.concurrent.ExecutorService
astore 2
start local 2 6: aload 1
getstatic reactor.core.Scannable$Attr.TERMINATED:Lreactor/core/Scannable$Attr;
if_acmpne 7
aload 2
invokeinterface java.util.concurrent.ExecutorService.isTerminated:()Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
7: StackMap locals: java.util.concurrent.ExecutorService
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.CANCELLED:Lreactor/core/Scannable$Attr;
if_acmpne 8
aload 2
invokeinterface java.util.concurrent.ExecutorService.isShutdown:()Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
end local 2 8: StackMap locals:
StackMap stack:
aload 0
instanceof java.util.concurrent.ThreadPoolExecutor
ifeq 13
9: aload 0
checkcast java.util.concurrent.ThreadPoolExecutor
astore 2
start local 2 10: aload 1
getstatic reactor.core.Scannable$Attr.CAPACITY:Lreactor/core/Scannable$Attr;
if_acmpne 11
aload 2
invokevirtual java.util.concurrent.ThreadPoolExecutor.getMaximumPoolSize:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
11: StackMap locals: java.util.concurrent.ThreadPoolExecutor
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.BUFFERED:Lreactor/core/Scannable$Attr;
if_acmpne 12
aload 2
invokevirtual java.util.concurrent.ThreadPoolExecutor.getTaskCount:()J
aload 2
invokevirtual java.util.concurrent.ThreadPoolExecutor.getCompletedTaskCount:()J
lsub
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokevirtual java.lang.Long.intValue:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
12: StackMap locals:
StackMap stack:
aload 1
getstatic reactor.core.Scannable$Attr.LARGE_BUFFERED:Lreactor/core/Scannable$Attr;
if_acmpne 13
aload 2
invokevirtual java.util.concurrent.ThreadPoolExecutor.getTaskCount:()J
aload 2
invokevirtual java.util.concurrent.ThreadPoolExecutor.getCompletedTaskCount:()J
lsub
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
areturn
end local 2 13: StackMap locals:
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 executor Ljava/util/concurrent/Executor;
0 14 1 key Lreactor/core/Scannable$Attr;
6 8 2 service Ljava/util/concurrent/ExecutorService;
10 13 2 poolExecutor Ljava/util/concurrent/ThreadPoolExecutor;
RuntimeVisibleAnnotations:
reactor.util.annotation.Nullable()
MethodParameters:
Name Flags
executor
key
private static java.lang.Integer lambda$1();
descriptor: ()Ljava/lang/Integer;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=0, args_size=0
0: invokestatic java.lang.Runtime.getRuntime:()Ljava/lang/Runtime;
invokevirtual java.lang.Runtime.availableProcessors:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.Integer lambda$3();
descriptor: ()Ljava/lang/Integer;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=0, args_size=0
0: bipush 10
invokestatic java.lang.Runtime.getRuntime:()Ljava/lang/Runtime;
invokevirtual java.lang.Runtime.availableProcessors:()I
imul
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static reactor.core.scheduler.Scheduler lambda$5();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=0, args_size=0
0: ldc "elastic"
bipush 60
iconst_1
invokestatic reactor.core.scheduler.Schedulers.newElastic:(Ljava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static reactor.core.scheduler.Scheduler lambda$6();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=0, args_size=0
0: getstatic reactor.core.scheduler.Schedulers.DEFAULT_BOUNDED_ELASTIC_SIZE:I
getstatic reactor.core.scheduler.Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE:I
1: ldc "boundedElastic"
bipush 60
iconst_1
2: invokestatic reactor.core.scheduler.Schedulers.newBoundedElastic:(IILjava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
3: areturn
LocalVariableTable:
Start End Slot Name Signature
private static reactor.core.scheduler.Scheduler lambda$7();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=0, args_size=0
0: ldc "parallel"
getstatic reactor.core.scheduler.Schedulers.DEFAULT_POOL_SIZE:I
iconst_1
invokestatic reactor.core.scheduler.Schedulers.newParallel:(Ljava/lang/String;IZ)Lreactor/core/scheduler/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static reactor.core.scheduler.Scheduler lambda$8();
descriptor: ()Lreactor/core/scheduler/Scheduler;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=0, args_size=0
0: ldc "single"
iconst_1
invokestatic reactor.core.scheduler.Schedulers.newSingle:(Ljava/lang/String;Z)Lreactor/core/scheduler/Scheduler;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "Schedulers.java"
NestMembers:
reactor.core.scheduler.Schedulers$1 reactor.core.scheduler.Schedulers$CachedScheduler reactor.core.scheduler.Schedulers$Factory reactor.core.scheduler.Schedulers$Snapshot
InnerClasses:
public abstract UncaughtExceptionHandler = java.lang.Thread$UncaughtExceptionHandler of java.lang.Thread
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Composite = reactor.core.Disposable$Composite of reactor.core.Disposable
public Attr = reactor.core.Scannable$Attr of reactor.core.Scannable
final UnsupportedScheduledExecutorService = reactor.core.scheduler.DelegateServiceScheduler$UnsupportedScheduledExecutorService of reactor.core.scheduler.DelegateServiceScheduler
reactor.core.scheduler.Schedulers$1
CachedScheduler = reactor.core.scheduler.Schedulers$CachedScheduler of reactor.core.scheduler.Schedulers
public abstract Factory = reactor.core.scheduler.Schedulers$Factory of reactor.core.scheduler.Schedulers
public final Snapshot = reactor.core.scheduler.Schedulers$Snapshot of reactor.core.scheduler.Schedulers
Schedulers
onHandleErrorHook: BiConsumer
onScheduleHooks: LinkedHashMap
