public final class org.jboss.threads.JBossScheduledThreadPoolExecutor extends java.util.concurrent.ScheduledThreadPoolExecutor
{
private final java.util.concurrent.atomic.AtomicInteger rejectCount;
private final java.lang.Runnable terminationTask;
public void <init>(int, java.lang.Runnable)
{
java.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
java.lang.Runnable v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: int;
v := @parameter: java.lang.Runnable;
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void <init>(int)>(v);
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.util.concurrent.atomic.AtomicInteger rejectCount> = v;
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.lang.Runnable terminationTask> = v;
v = specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()>();
virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler)>(v);
return;
}
public void <init>(int, java.util.concurrent.ThreadFactory, java.lang.Runnable)
{
java.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
java.util.concurrent.ThreadFactory v;
java.lang.Runnable v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: int;
v := @parameter: java.util.concurrent.ThreadFactory;
v := @parameter: java.lang.Runnable;
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void <init>(int,java.util.concurrent.ThreadFactory)>(v, v);
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.util.concurrent.atomic.AtomicInteger rejectCount> = v;
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.lang.Runnable terminationTask> = v;
v = specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()>();
virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler)>(v);
return;
}
public void <init>(int, java.util.concurrent.RejectedExecutionHandler, java.lang.Runnable)
{
java.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
java.lang.Runnable v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: int;
v := @parameter: java.util.concurrent.RejectedExecutionHandler;
v := @parameter: java.lang.Runnable;
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void <init>(int)>(v);
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.util.concurrent.atomic.AtomicInteger rejectCount> = v;
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.lang.Runnable terminationTask> = v;
virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler)>(v);
return;
}
public void <init>(int, java.util.concurrent.ThreadFactory, java.util.concurrent.RejectedExecutionHandler, java.lang.Runnable)
{
java.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
java.util.concurrent.ThreadFactory v;
java.lang.Runnable v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: int;
v := @parameter: java.util.concurrent.ThreadFactory;
v := @parameter: java.util.concurrent.RejectedExecutionHandler;
v := @parameter: java.lang.Runnable;
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void <init>(int,java.util.concurrent.ThreadFactory)>(v, v);
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.util.concurrent.atomic.AtomicInteger rejectCount> = v;
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.lang.Runnable terminationTask> = v;
virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler)>(v);
return;
}
public long getKeepAliveTime()
{
java.util.concurrent.TimeUnit v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
long v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: long getKeepAliveTime(java.util.concurrent.TimeUnit)>(v);
return v;
}
public void setKeepAliveTime(long)
{
java.util.concurrent.TimeUnit v;
byte v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
long v;
boolean v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: long;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void setKeepAliveTime(long,java.util.concurrent.TimeUnit)>(v, v);
v = v cmp 9223372036854775807L;
if v >= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void allowCoreThreadTimeOut(boolean)>(v);
return;
}
public void setKeepAliveTime(long, java.util.concurrent.TimeUnit)
{
java.util.concurrent.TimeUnit v;
byte v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
long v;
boolean v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void setKeepAliveTime(long,java.util.concurrent.TimeUnit)>(v, v);
v = v cmp 9223372036854775807L;
if v >= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void allowCoreThreadTimeOut(boolean)>(v);
return;
}
public int getRejectedCount()
{
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
java.util.concurrent.atomic.AtomicInteger v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v = v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.util.concurrent.atomic.AtomicInteger rejectCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
return v;
}
public int getCurrentThreadCount()
{
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v = virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: int getActiveCount()>();
return v;
}
public int getLargestThreadCount()
{
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v = virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: int getLargestPoolSize()>();
return v;
}
public int getMaxThreads()
{
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v = virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: int getCorePoolSize()>();
return v;
}
public void setMaxThreads(int)
{
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: int;
virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: void setCorePoolSize(int)>(v);
return;
}
public java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()
{
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
java.util.concurrent.RejectedExecutionHandler v, v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v = specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()>();
v = virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler: java.util.concurrent.RejectedExecutionHandler getDelegate()>();
return v;
}
public void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler)
{
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler v;
java.util.concurrent.RejectedExecutionHandler v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: java.util.concurrent.RejectedExecutionHandler;
v = new org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler;
specialinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler: void <init>(org.jboss.threads.JBossScheduledThreadPoolExecutor,java.util.concurrent.RejectedExecutionHandler)>(v, v);
specialinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler)>(v);
return;
}
public int getQueueSize()
{
int v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
java.util.concurrent.BlockingQueue v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v = virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.util.concurrent.BlockingQueue getQueue()>();
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: int size()>();
return v;
}
protected void terminated()
{
org.jboss.threads.JBossScheduledThreadPoolExecutor v;
java.lang.Runnable v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v = v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.lang.Runnable terminationTask>;
interfaceinvoke v.<java.lang.Runnable: void run()>();
return;
}
}