public final class oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor extends java.util.concurrent.ThreadPoolExecutor
{
private static final org.slf4j.Logger LOG;
public void <init>(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue)
{
java.util.concurrent.TimeUnit v;
int v, v;
java.util.concurrent.BlockingQueue v;
long v;
oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor v;
v := @this: oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v := @parameter: java.util.concurrent.BlockingQueue;
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor: void <init>(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue)>(v, v, v, v, v);
return;
}
public void <init>(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue, java.util.concurrent.ThreadFactory)
{
java.util.concurrent.TimeUnit v;
int v, v;
java.util.concurrent.BlockingQueue v;
long v;
java.util.concurrent.ThreadFactory v;
oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor v;
v := @this: oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v := @parameter: java.util.concurrent.BlockingQueue;
v := @parameter: java.util.concurrent.ThreadFactory;
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor: void <init>(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.ThreadFactory)>(v, v, v, v, v, v);
return;
}
public void <init>(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue, java.util.concurrent.RejectedExecutionHandler)
{
java.util.concurrent.TimeUnit v;
java.util.concurrent.RejectedExecutionHandler v;
int v, v;
java.util.concurrent.BlockingQueue v;
long v;
oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor v;
v := @this: oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v := @parameter: java.util.concurrent.BlockingQueue;
v := @parameter: java.util.concurrent.RejectedExecutionHandler;
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor: void <init>(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.RejectedExecutionHandler)>(v, v, v, v, v, v);
return;
}
public void <init>(int, int, long, java.util.concurrent.TimeUnit, java.util.concurrent.BlockingQueue, java.util.concurrent.ThreadFactory, java.util.concurrent.RejectedExecutionHandler)
{
java.util.concurrent.BlockingQueue v;
long v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.RejectedExecutionHandler v;
int v, v;
java.util.concurrent.ThreadFactory v;
oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor v;
v := @this: oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v := @parameter: java.util.concurrent.BlockingQueue;
v := @parameter: java.util.concurrent.ThreadFactory;
v := @parameter: java.util.concurrent.RejectedExecutionHandler;
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor: void <init>(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.ThreadFactory,java.util.concurrent.RejectedExecutionHandler)>(v, v, v, v, v, v, v);
return;
}
protected void beforeExecute(java.lang.Thread, java.lang.Runnable)
{
org.slf4j.Logger v, v;
java.lang.Runnable v;
java.lang.Thread v, v;
java.lang.Class v;
java.lang.String v, v, v;
boolean v;
oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor v;
v := @this: oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor;
v := @parameter: java.lang.Thread;
v := @parameter: java.lang.Runnable;
v = <oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("beforeExecute in thread: \u, runnable type: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>(v);
label:
return;
}
protected void afterExecute(java.lang.Runnable, java.lang.Throwable)
{
java.lang.Throwable v;
java.lang.Runnable v;
oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor v;
v := @this: oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor;
v := @parameter: java.lang.Runnable;
v := @parameter: java.lang.Throwable;
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor: void afterExecute(java.lang.Runnable,java.lang.Throwable)>(v, v);
staticinvoke <oadd.org.apache.hadoop.util.concurrent.ExecutorHelper: void logThrowableFromAfterExecute(java.lang.Runnable,java.lang.Throwable)>(v, v);
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/util/concurrent/HadoopThreadPoolExecutor;");
<oadd.org.apache.hadoop.util.concurrent.HadoopThreadPoolExecutor: org.slf4j.Logger LOG> = v;
return;
}
}