public class io.dropwizard.lifecycle.setup.ExecutorServiceBuilder
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.dropwizard.lifecycle.setup.ExecutorServiceBuilder
super_class: java.lang.Object
{
private static org.slf4j.Logger log;
descriptor: Lorg/slf4j/Logger;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
private final io.dropwizard.lifecycle.setup.LifecycleEnvironment environment;
descriptor: Lio/dropwizard/lifecycle/setup/LifecycleEnvironment;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.String nameFormat;
descriptor: Ljava/lang/String;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private int corePoolSize;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private int maximumPoolSize;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private boolean allowCoreThreadTimeOut;
descriptor: Z
flags: (0x0002) ACC_PRIVATE
private io.dropwizard.util.Duration keepAliveTime;
descriptor: Lio/dropwizard/util/Duration;
flags: (0x0002) ACC_PRIVATE
private io.dropwizard.util.Duration shutdownTime;
descriptor: Lio/dropwizard/util/Duration;
flags: (0x0002) ACC_PRIVATE
private java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue;
descriptor: Ljava/util/concurrent/BlockingQueue;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
private java.util.concurrent.ThreadFactory threadFactory;
descriptor: Ljava/util/concurrent/ThreadFactory;
flags: (0x0002) ACC_PRIVATE
private java.util.concurrent.RejectedExecutionHandler handler;
descriptor: Ljava/util/concurrent/RejectedExecutionHandler;
flags: (0x0002) ACC_PRIVATE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.log:Lorg/slf4j/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(io.dropwizard.lifecycle.setup.LifecycleEnvironment, java.lang.String, java.util.concurrent.ThreadFactory);
descriptor: (Lio/dropwizard/lifecycle/setup/LifecycleEnvironment;Ljava/lang/String;Ljava/util/concurrent/ThreadFactory;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.environment:Lio/dropwizard/lifecycle/setup/LifecycleEnvironment;
2: aload 0
aload 2
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.nameFormat:Ljava/lang/String;
3: aload 0
iconst_0
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.corePoolSize:I
4: aload 0
iconst_1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.maximumPoolSize:I
5: aload 0
iconst_0
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.allowCoreThreadTimeOut:Z
6: aload 0
ldc 60
invokestatic io.dropwizard.util.Duration.seconds:(J)Lio/dropwizard/util/Duration;
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.keepAliveTime:Lio/dropwizard/util/Duration;
7: aload 0
ldc 5
invokestatic io.dropwizard.util.Duration.seconds:(J)Lio/dropwizard/util/Duration;
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.shutdownTime:Lio/dropwizard/util/Duration;
8: aload 0
new java.util.concurrent.LinkedBlockingQueue
dup
invokespecial java.util.concurrent.LinkedBlockingQueue.<init>:()V
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.workQueue:Ljava/util/concurrent/BlockingQueue;
9: aload 0
aload 3
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.threadFactory:Ljava/util/concurrent/ThreadFactory;
10: aload 0
new java.util.concurrent.ThreadPoolExecutor$AbortPolicy
dup
invokespecial java.util.concurrent.ThreadPoolExecutor$AbortPolicy.<init>:()V
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.handler:Ljava/util/concurrent/RejectedExecutionHandler;
11: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 12 1 environment Lio/dropwizard/lifecycle/setup/LifecycleEnvironment;
0 12 2 nameFormat Ljava/lang/String;
0 12 3 factory Ljava/util/concurrent/ThreadFactory;
MethodParameters:
Name Flags
environment
nameFormat
factory
public void <init>(io.dropwizard.lifecycle.setup.LifecycleEnvironment, java.lang.String);
descriptor: (Lio/dropwizard/lifecycle/setup/LifecycleEnvironment;Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
new com.google.common.util.concurrent.ThreadFactoryBuilder
dup
invokespecial com.google.common.util.concurrent.ThreadFactoryBuilder.<init>:()V
aload 2
invokevirtual com.google.common.util.concurrent.ThreadFactoryBuilder.setNameFormat:(Ljava/lang/String;)Lcom/google/common/util/concurrent/ThreadFactoryBuilder;
invokevirtual com.google.common.util.concurrent.ThreadFactoryBuilder.build:()Ljava/util/concurrent/ThreadFactory;
invokespecial io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.<init>:(Lio/dropwizard/lifecycle/setup/LifecycleEnvironment;Ljava/lang/String;Ljava/util/concurrent/ThreadFactory;)V
1: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 environment Lio/dropwizard/lifecycle/setup/LifecycleEnvironment;
0 2 2 nameFormat Ljava/lang/String;
MethodParameters:
Name Flags
environment
nameFormat
public io.dropwizard.lifecycle.setup.ExecutorServiceBuilder minThreads(int);
descriptor: (I)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.corePoolSize:I
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 threads I
MethodParameters:
Name Flags
threads
public io.dropwizard.lifecycle.setup.ExecutorServiceBuilder maxThreads(int);
descriptor: (I)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.maximumPoolSize:I
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 threads I
MethodParameters:
Name Flags
threads
public io.dropwizard.lifecycle.setup.ExecutorServiceBuilder allowCoreThreadTimeOut(boolean);
descriptor: (Z)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.allowCoreThreadTimeOut:Z
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 allowCoreThreadTimeOut Z
MethodParameters:
Name Flags
allowCoreThreadTimeOut
public io.dropwizard.lifecycle.setup.ExecutorServiceBuilder keepAliveTime(io.dropwizard.util.Duration);
descriptor: (Lio/dropwizard/util/Duration;)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.keepAliveTime:Lio/dropwizard/util/Duration;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 time Lio/dropwizard/util/Duration;
MethodParameters:
Name Flags
time
public io.dropwizard.lifecycle.setup.ExecutorServiceBuilder shutdownTime(io.dropwizard.util.Duration);
descriptor: (Lio/dropwizard/util/Duration;)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.shutdownTime:Lio/dropwizard/util/Duration;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 time Lio/dropwizard/util/Duration;
MethodParameters:
Name Flags
time
public io.dropwizard.lifecycle.setup.ExecutorServiceBuilder workQueue(java.util.concurrent.BlockingQueue<java.lang.Runnable>);
descriptor: (Ljava/util/concurrent/BlockingQueue;)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.workQueue:Ljava/util/concurrent/BlockingQueue;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 workQueue Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;
Signature: (Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>;)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
MethodParameters:
Name Flags
workQueue
public io.dropwizard.lifecycle.setup.ExecutorServiceBuilder rejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler);
descriptor: (Ljava/util/concurrent/RejectedExecutionHandler;)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.handler:Ljava/util/concurrent/RejectedExecutionHandler;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 handler Ljava/util/concurrent/RejectedExecutionHandler;
MethodParameters:
Name Flags
handler
public io.dropwizard.lifecycle.setup.ExecutorServiceBuilder threadFactory(java.util.concurrent.ThreadFactory);
descriptor: (Ljava/util/concurrent/ThreadFactory;)Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.threadFactory:Ljava/util/concurrent/ThreadFactory;
1: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
0 2 1 threadFactory Ljava/util/concurrent/ThreadFactory;
MethodParameters:
Name Flags
threadFactory
public java.util.concurrent.ExecutorService build();
descriptor: ()Ljava/util/concurrent/ExecutorService;
flags: (0x0001) ACC_PUBLIC
Code:
stack=10, locals=2, args_size=1
start local 0 0: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.corePoolSize:I
aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.maximumPoolSize:I
if_icmpeq 2
aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.maximumPoolSize:I
iconst_1
if_icmple 2
aload 0
invokevirtual io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.isBoundedQueue:()Z
ifne 2
1: getstatic io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.log:Lorg/slf4j/Logger;
ldc "Parameter 'maximumPoolSize' is conflicting with unbounded work queues"
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;)V
2: StackMap locals:
StackMap stack:
new java.util.concurrent.ThreadPoolExecutor
dup
aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.corePoolSize:I
3: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.maximumPoolSize:I
4: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.keepAliveTime:Lio/dropwizard/util/Duration;
invokevirtual io.dropwizard.util.Duration.getQuantity:()J
5: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.keepAliveTime:Lio/dropwizard/util/Duration;
invokevirtual io.dropwizard.util.Duration.getUnit:()Ljava/util/concurrent/TimeUnit;
6: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.workQueue:Ljava/util/concurrent/BlockingQueue;
7: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.threadFactory:Ljava/util/concurrent/ThreadFactory;
8: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.handler:Ljava/util/concurrent/RejectedExecutionHandler;
9: invokespecial java.util.concurrent.ThreadPoolExecutor.<init>:(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;Ljava/util/concurrent/RejectedExecutionHandler;)V
astore 1
start local 1 10: aload 1
aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.allowCoreThreadTimeOut:Z
invokevirtual java.util.concurrent.ThreadPoolExecutor.allowCoreThreadTimeOut:(Z)V
11: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.environment:Lio/dropwizard/lifecycle/setup/LifecycleEnvironment;
new io.dropwizard.lifecycle.ExecutorServiceManager
dup
aload 1
aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.shutdownTime:Lio/dropwizard/util/Duration;
aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.nameFormat:Ljava/lang/String;
invokespecial io.dropwizard.lifecycle.ExecutorServiceManager.<init>:(Ljava/util/concurrent/ExecutorService;Lio/dropwizard/util/Duration;Ljava/lang/String;)V
invokevirtual io.dropwizard.lifecycle.setup.LifecycleEnvironment.manage:(Lio/dropwizard/lifecycle/Managed;)V
12: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
10 13 1 executor Ljava/util/concurrent/ThreadPoolExecutor;
private boolean isBoundedQueue();
descriptor: ()Z
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.workQueue:Ljava/util/concurrent/BlockingQueue;
invokeinterface java.util.concurrent.BlockingQueue.remainingCapacity:()I
ldc 2147483647
if_icmpeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lio/dropwizard/lifecycle/setup/ExecutorServiceBuilder;
static synchronized void setLog(org.slf4j.Logger);
descriptor: (Lorg/slf4j/Logger;)V
flags: (0x0028) ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
putstatic io.dropwizard.lifecycle.setup.ExecutorServiceBuilder.log:Lorg/slf4j/Logger;
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 newLog Lorg/slf4j/Logger;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
newLog
}
SourceFile: "ExecutorServiceBuilder.java"
InnerClasses:
public AbortPolicy = java.util.concurrent.ThreadPoolExecutor$AbortPolicy of java.util.concurrent.ThreadPoolExecutor