public final class oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService extends oadd.org.apache.hadoop.util.SemaphoredDelegatingExecutor
{
private static final org.slf4j.Logger LOG;
private static final java.util.concurrent.atomic.AtomicInteger POOLNUMBER;
private final java.util.concurrent.ThreadPoolExecutor eventProcessingExecutor;
static java.util.concurrent.ThreadFactory getNamedThreadFactory(java.lang.String)
{
oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$1 v;
java.lang.Thread v;
java.lang.String v;
java.lang.ThreadGroup v;
java.lang.SecurityManager v;
v := @parameter: java.lang.String;
v = staticinvoke <java.lang.System: java.lang.SecurityManager getSecurityManager()>();
if v == null goto label;
v = virtualinvoke v.<java.lang.SecurityManager: java.lang.ThreadGroup getThreadGroup()>();
goto label;
label:
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.ThreadGroup getThreadGroup()>();
label:
v = new oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$1;
specialinvoke v.<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$1: void <init>(java.lang.ThreadGroup,java.lang.String)>(v, v);
return v;
}
public static java.util.concurrent.ThreadFactory newDaemonThreadFactory(java.lang.String)
{
java.lang.String v;
oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$2 v;
java.util.concurrent.ThreadFactory v;
v := @parameter: java.lang.String;
v = staticinvoke <oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService: java.util.concurrent.ThreadFactory getNamedThreadFactory(java.lang.String)>(v);
v = new oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$2;
specialinvoke v.<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$2: void <init>(java.util.concurrent.ThreadFactory)>(v);
return v;
}
private void <init>(int, java.util.concurrent.ThreadPoolExecutor)
{
int v;
java.util.concurrent.ThreadPoolExecutor v;
oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService v;
v := @this: oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService;
v := @parameter: int;
v := @parameter: java.util.concurrent.ThreadPoolExecutor;
specialinvoke v.<oadd.org.apache.hadoop.util.SemaphoredDelegatingExecutor: void <init>(java.util.concurrent.ExecutorService,int,boolean)>(v, v, 0);
v.<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService: java.util.concurrent.ThreadPoolExecutor eventProcessingExecutor> = v;
return;
}
public static oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService newInstance(int, int, long, java.util.concurrent.TimeUnit, java.lang.String)
{
java.util.concurrent.ThreadPoolExecutor v;
long v;
oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$3 v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.concurrent.TimeUnit v;
oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService v;
int v, v, v, v;
java.lang.String v;
java.util.concurrent.ThreadFactory v;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v := @parameter: java.lang.String;
v = new java.util.concurrent.LinkedBlockingQueue;
v = v + v;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>(int)>(v);
v = new java.util.concurrent.ThreadPoolExecutor;
v = staticinvoke <oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService: java.util.concurrent.ThreadFactory newDaemonThreadFactory(java.lang.String)>(v);
v = new oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$3;
specialinvoke v.<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService$3: void <init>()>();
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);
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: void allowCoreThreadTimeOut(boolean)>(1);
v = new oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService;
v = v + v;
specialinvoke v.<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService: void <init>(int,java.util.concurrent.ThreadPoolExecutor)>(v, v);
return v;
}
int getActiveCount()
{
int v;
java.util.concurrent.ThreadPoolExecutor v;
oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService v;
v := @this: oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService;
v = v.<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService: java.util.concurrent.ThreadPoolExecutor eventProcessingExecutor>;
v = virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: int getActiveCount()>();
return v;
}
public java.lang.String toString()
{
oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService v;
int v;
java.lang.StringBuilder v, v;
java.lang.String v, v;
v := @this: oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>(java.lang.String)>("BlockingThreadPoolExecutorService{");
v = specialinvoke v.<oadd.org.apache.hadoop.util.SemaphoredDelegatingExecutor: java.lang.String toString()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", activeCount=");
v = virtualinvoke v.<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService: int getActiveCount()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(char)>(125);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.util.concurrent.atomic.AtomicInteger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/util/BlockingThreadPoolExecutorService;");
<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService: org.slf4j.Logger LOG> = v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>(int)>(1);
<oadd.org.apache.hadoop.util.BlockingThreadPoolExecutorService: java.util.concurrent.atomic.AtomicInteger POOLNUMBER> = v;
return;
}
}