public interface reactor.core.scheduler.Schedulers$Factory
minor version: 0
major version: 59
flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
this_class: reactor.core.scheduler.Schedulers$Factory
super_class: java.lang.Object
{
public reactor.core.scheduler.Scheduler newElastic(int, java.util.concurrent.ThreadFactory);
descriptor: (ILjava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new reactor.core.scheduler.ElasticScheduler
dup
aload 2
iload 1
invokespecial reactor.core.scheduler.ElasticScheduler.<init>:(Ljava/util/concurrent/ThreadFactory;I)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/scheduler/Schedulers$Factory;
0 1 1 ttlSeconds I
0 1 2 threadFactory Ljava/util/concurrent/ThreadFactory;
RuntimeVisibleAnnotations:
java.lang.Deprecated()
MethodParameters:
Name Flags
ttlSeconds
threadFactory
public reactor.core.scheduler.Scheduler newBoundedElastic(int, int, java.util.concurrent.ThreadFactory, int);
descriptor: (IILjava/util/concurrent/ThreadFactory;I)Lreactor/core/scheduler/Scheduler;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new reactor.core.scheduler.BoundedElasticScheduler
dup
iload 1
iload 2
aload 3
iload 4
invokespecial reactor.core.scheduler.BoundedElasticScheduler.<init>:(IILjava/util/concurrent/ThreadFactory;I)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/scheduler/Schedulers$Factory;
0 1 1 threadCap I
0 1 2 queuedTaskCap I
0 1 3 threadFactory Ljava/util/concurrent/ThreadFactory;
0 1 4 ttlSeconds I
MethodParameters:
Name Flags
threadCap
queuedTaskCap
threadFactory
ttlSeconds
public reactor.core.scheduler.Scheduler newParallel(int, java.util.concurrent.ThreadFactory);
descriptor: (ILjava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: new reactor.core.scheduler.ParallelScheduler
dup
iload 1
aload 2
invokespecial reactor.core.scheduler.ParallelScheduler.<init>:(ILjava/util/concurrent/ThreadFactory;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/scheduler/Schedulers$Factory;
0 1 1 parallelism I
0 1 2 threadFactory Ljava/util/concurrent/ThreadFactory;
MethodParameters:
Name Flags
parallelism
threadFactory
public reactor.core.scheduler.Scheduler newSingle(java.util.concurrent.ThreadFactory);
descriptor: (Ljava/util/concurrent/ThreadFactory;)Lreactor/core/scheduler/Scheduler;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: new reactor.core.scheduler.SingleScheduler
dup
aload 1
invokespecial reactor.core.scheduler.SingleScheduler.<init>:(Ljava/util/concurrent/ThreadFactory;)V
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lreactor/core/scheduler/Schedulers$Factory;
0 1 1 threadFactory Ljava/util/concurrent/ThreadFactory;
MethodParameters:
Name Flags
threadFactory
}
SourceFile: "Schedulers.java"
NestHost: reactor.core.scheduler.Schedulers
InnerClasses:
public abstract Factory = reactor.core.scheduler.Schedulers$Factory of reactor.core.scheduler.Schedulers