final class org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler extends java.lang.Object implements java.util.concurrent.RejectedExecutionHandler
{
private final java.util.concurrent.RejectedExecutionHandler delegate;
final org.jboss.threads.JBossScheduledThreadPoolExecutor this$0;
public void <init>(org.jboss.threads.JBossScheduledThreadPoolExecutor, 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$CountingRejectHandler;
v := @parameter: org.jboss.threads.JBossScheduledThreadPoolExecutor;
v := @parameter: java.util.concurrent.RejectedExecutionHandler;
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler: org.jboss.threads.JBossScheduledThreadPoolExecutor this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler: java.util.concurrent.RejectedExecutionHandler delegate> = v;
return;
}
public java.util.concurrent.RejectedExecutionHandler getDelegate()
{
org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler v;
java.util.concurrent.RejectedExecutionHandler v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler;
v = v.<org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler: java.util.concurrent.RejectedExecutionHandler delegate>;
return v;
}
public void rejectedExecution(java.lang.Runnable, java.util.concurrent.ThreadPoolExecutor)
{
java.util.concurrent.ThreadPoolExecutor v;
org.jboss.threads.JBossScheduledThreadPoolExecutor v, v;
java.lang.Runnable v;
org.jboss.threads.StoppedExecutorException v;
java.util.concurrent.RejectedExecutionHandler v;
java.util.concurrent.atomic.AtomicInteger v;
org.jboss.threads.Messages v;
org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler v;
boolean v;
v := @this: org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler;
v := @parameter: java.lang.Runnable;
v := @parameter: java.util.concurrent.ThreadPoolExecutor;
v = v.<org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler: org.jboss.threads.JBossScheduledThreadPoolExecutor this$0>;
v = v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: java.util.concurrent.atomic.AtomicInteger rejectCount>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
v = v.<org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler: org.jboss.threads.JBossScheduledThreadPoolExecutor this$0>;
v = virtualinvoke v.<org.jboss.threads.JBossScheduledThreadPoolExecutor: boolean isShutdown()>();
if v == 0 goto label;
v = <org.jboss.threads.Messages: org.jboss.threads.Messages msg>;
v = interfaceinvoke v.<org.jboss.threads.Messages: org.jboss.threads.StoppedExecutorException shutDownInitiated()>();
throw v;
label:
v = v.<org.jboss.threads.JBossScheduledThreadPoolExecutor$CountingRejectHandler: java.util.concurrent.RejectedExecutionHandler delegate>;
interfaceinvoke v.<java.util.concurrent.RejectedExecutionHandler: void rejectedExecution(java.lang.Runnable,java.util.concurrent.ThreadPoolExecutor)>(v, v);
return;
}
}