public class com.lmax.disruptor.dsl.BasicExecutor implements java.util.concurrent.Executor
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.lmax.disruptor.dsl.BasicExecutor
super_class: java.lang.Object
{
private final java.util.concurrent.ThreadFactory factory;
descriptor: Ljava/util/concurrent/ThreadFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Queue<java.lang.Thread> threads;
descriptor: Ljava/util/Queue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Queue<Ljava/lang/Thread;>;
public void <init>(java.util.concurrent.ThreadFactory);
descriptor: (Ljava/util/concurrent/ThreadFactory;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.ConcurrentLinkedQueue
dup
invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:()V
putfield com.lmax.disruptor.dsl.BasicExecutor.threads:Ljava/util/Queue;
2: aload 0
aload 1
putfield com.lmax.disruptor.dsl.BasicExecutor.factory:Ljava/util/concurrent/ThreadFactory;
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/lmax/disruptor/dsl/BasicExecutor;
0 4 1 factory Ljava/util/concurrent/ThreadFactory;
MethodParameters:
Name Flags
factory
public void execute(java.lang.Runnable);
descriptor: (Ljava/lang/Runnable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield com.lmax.disruptor.dsl.BasicExecutor.factory:Ljava/util/concurrent/ThreadFactory;
aload 1
invokeinterface java.util.concurrent.ThreadFactory.newThread:(Ljava/lang/Runnable;)Ljava/lang/Thread;
astore 2
start local 2 1: aload 2
ifnonnull 3
2: new java.lang.RuntimeException
dup
new java.lang.StringBuilder
dup
ldc "Failed to create thread to run: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 1
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
athrow
3: StackMap locals: java.lang.Thread
StackMap stack:
aload 2
invokevirtual java.lang.Thread.start:()V
4: aload 0
getfield com.lmax.disruptor.dsl.BasicExecutor.threads:Ljava/util/Queue;
aload 2
invokeinterface java.util.Queue.add:(Ljava/lang/Object;)Z
pop
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lcom/lmax/disruptor/dsl/BasicExecutor;
0 6 1 command Ljava/lang/Runnable;
1 6 2 thread Ljava/lang/Thread;
MethodParameters:
Name Flags
command
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "BasicExecutor{threads="
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
1: aload 0
invokevirtual com.lmax.disruptor.dsl.BasicExecutor.dumpThreadInfo:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: bipush 125
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
3: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lcom/lmax/disruptor/dsl/BasicExecutor;
private java.lang.String dumpThreadInfo();
descriptor: ()Ljava/lang/String;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=6, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
invokespecial java.lang.StringBuilder.<init>:()V
astore 1
start local 1 1: invokestatic java.lang.management.ManagementFactory.getThreadMXBean:()Ljava/lang/management/ThreadMXBean;
astore 2
start local 2 2: aload 0
getfield com.lmax.disruptor.dsl.BasicExecutor.threads:Ljava/util/Queue;
invokeinterface java.util.Queue.iterator:()Ljava/util/Iterator;
astore 4
goto 11
StackMap locals: com.lmax.disruptor.dsl.BasicExecutor java.lang.StringBuilder java.lang.management.ThreadMXBean top java.util.Iterator
StackMap stack:
3: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.Thread
astore 3
start local 3 4: aload 2
aload 3
invokevirtual java.lang.Thread.getId:()J
invokeinterface java.lang.management.ThreadMXBean.getThreadInfo:(J)Ljava/lang/management/ThreadInfo;
astore 5
start local 5 5: aload 1
ldc "{"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
6: aload 1
ldc "name="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokevirtual java.lang.Thread.getName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc ","
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
7: aload 1
ldc "id="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokevirtual java.lang.Thread.getId:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc ","
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
8: aload 1
ldc "state="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 5
invokevirtual java.lang.management.ThreadInfo.getThreadState:()Ljava/lang/Thread$State;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc ","
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
9: aload 1
ldc "lockInfo="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 5
invokevirtual java.lang.management.ThreadInfo.getLockInfo:()Ljava/lang/management/LockInfo;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
pop
10: aload 1
ldc "}"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
pop
end local 5 end local 3 11: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
12: aload 1
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lcom/lmax/disruptor/dsl/BasicExecutor;
1 13 1 sb Ljava/lang/StringBuilder;
2 13 2 threadMXBean Ljava/lang/management/ThreadMXBean;
4 11 3 t Ljava/lang/Thread;
5 11 5 threadInfo Ljava/lang/management/ThreadInfo;
}
SourceFile: "BasicExecutor.java"
InnerClasses:
public final State = java.lang.Thread$State of java.lang.Thread