final class org.apache.cassandra.cql3.functions.UDFExecutorService extends org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
minor version: 0
major version: 59
flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
this_class: org.apache.cassandra.cql3.functions.UDFExecutorService
super_class: org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
{
private static int KEEPALIVE;
descriptor: I
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: ldc "cassandra.udf_executor_thread_keepalive_ms"
sipush 30000
invokestatic java.lang.Integer.getInteger:(Ljava/lang/String;I)Ljava/lang/Integer;
invokevirtual java.lang.Integer.intValue:()I
putstatic org.apache.cassandra.cql3.functions.UDFExecutorService.KEEPALIVE:I
return
LocalVariableTable:
Start End Slot Name Signature
void <init>(org.apache.cassandra.concurrent.NamedThreadFactory, java.lang.String);
descriptor: (Lorg/apache/cassandra/concurrent/NamedThreadFactory;Ljava/lang/String;)V
flags: (0x0000)
Code:
stack=8, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokestatic org.apache.cassandra.utils.FBUtilities.getAvailableProcessors:()I
1: getstatic org.apache.cassandra.cql3.functions.UDFExecutorService.KEEPALIVE:I
i2l
2: getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
3: new java.util.concurrent.LinkedBlockingQueue
dup
invokespecial java.util.concurrent.LinkedBlockingQueue.<init>:()V
4: aload 1
5: aload 2
invokespecial org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor.<init>:(IJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Lorg/apache/cassandra/concurrent/NamedThreadFactory;Ljava/lang/String;)V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/cql3/functions/UDFExecutorService;
0 7 1 threadFactory Lorg/apache/cassandra/concurrent/NamedThreadFactory;
0 7 2 jmxPath Ljava/lang/String;
MethodParameters:
Name Flags
threadFactory
jmxPath
protected void afterExecute(java.lang.Runnable, java.lang.Throwable);
descriptor: (Ljava/lang/Runnable;Ljava/lang/Throwable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=3, args_size=3
start local 0 start local 1 start local 2 0: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/functions/UDFExecutorService;
0 1 1 r Ljava/lang/Runnable;
0 1 2 t Ljava/lang/Throwable;
MethodParameters:
Name Flags
r
t
protected void beforeExecute(java.lang.Thread, java.lang.Runnable);
descriptor: (Ljava/lang/Thread;Ljava/lang/Runnable;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=0, locals=3, args_size=3
start local 0 start local 1 start local 2 0: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/cql3/functions/UDFExecutorService;
0 1 1 t Ljava/lang/Thread;
0 1 2 r Ljava/lang/Runnable;
MethodParameters:
Name Flags
t
r
}
SourceFile: "UDFExecutorService.java"