public final class org.jboss.threads.EnhancedQueueExecutor extends org.jboss.threads.EnhancedQueueExecutorBase implements org.jboss.threads.management.ManageableThreadPoolExecutorService, java.util.concurrent.ScheduledExecutorService { private static final java.lang.Thread[] NO_THREADS; public static final boolean DISABLE_HINT; static final boolean UPDATE_STATISTICS; static final boolean UPDATE_ACTIVE_COUNT; static final boolean NO_QUEUE_LIMIT; static final boolean REGISTER_MBEAN; static final boolean DISABLE_MBEAN; static final int PARK_SPINS; static final int YIELD_FACTOR; static final java.util.concurrent.Executor DEFAULT_HANDLER; private final java.util.concurrent.ThreadFactory threadFactory; private final java.util.Set runningThreads; private final org.jboss.threads.EnhancedQueueExecutor$MXBeanImpl mxBean; private final java.lang.Object handle; private volatile java.security.AccessControlContext acc; private final org.jboss.threads.ContextHandler contextHandler; private final org.jboss.threads.EnhancedQueueExecutor$SchedulerTask schedulerTask; private final java.lang.Thread schedulerThread; volatile org.jboss.threads.Waiter terminationWaiters; volatile long queueSize; volatile long timeoutNanos; volatile float growthResistance; volatile java.util.concurrent.Executor handoffExecutor; volatile java.lang.Thread$UncaughtExceptionHandler exceptionHandler; volatile java.lang.Runnable terminationTask; volatile int peakThreadCount; volatile int peakQueueSize; private final java.util.concurrent.atomic.LongAdder submittedTaskCounter; private final java.util.concurrent.atomic.LongAdder completedTaskCounter; private final java.util.concurrent.atomic.LongAdder rejectedTaskCounter; private final java.util.concurrent.atomic.LongAdder spinMisses; volatile int activeCount; private static final long terminationWaitersOffset; private static final long queueSizeOffset; private static final long peakThreadCountOffset; private static final long activeCountOffset; private static final long peakQueueSizeOffset; private static final long TS_THREAD_CNT_MASK; private static final long TS_CURRENT_SHIFT; private static final long TS_CORE_SHIFT; private static final long TS_MAX_SHIFT; private static final long TS_ALLOW_CORE_TIMEOUT; private static final long TS_SHUTDOWN_REQUESTED; private static final long TS_SHUTDOWN_INTERRUPT; private static final long TS_SHUTDOWN_COMPLETE; private static final int EXE_OK; private static final int EXE_REJECT_QUEUE_FULL; private static final int EXE_REJECT_SHUTDOWN; private static final int EXE_CREATE_THREAD; private static final int AT_YES; private static final int AT_NO; private static final int AT_SHUTDOWN; static final org.jboss.threads.EnhancedQueueExecutor$QNode TERMINATE_REQUESTED; static final org.jboss.threads.EnhancedQueueExecutor$QNode TERMINATE_COMPLETE; static final org.jboss.threads.Waiter TERMINATE_COMPLETE_WAITER; static final java.lang.Runnable WAITING; static final java.lang.Runnable GAVE_UP; static final java.lang.Runnable ACCEPTED; static final java.lang.Runnable EXIT; static final java.util.concurrent.atomic.AtomicInteger sequence; static final int ASF_ST_WAITING; static final int ASF_ST_CANCELLED; static final int ASF_ST_SUBMITTED; static final int ASF_ST_RUNNING; static final int ASF_ST_FINISHED; static final int ASF_ST_FAILED; static final int ASF_ST_REJECTED; static final org.jboss.threads.EnhancedQueueExecutor$AbstractScheduledFuture[] NO_FUTURES; static final java.util.concurrent.atomic.AtomicLong SCHEDULED_TASK_SEQ; static final boolean $assertionsDisabled; void (org.jboss.threads.EnhancedQueueExecutor$Builder) { java.security.AccessControlContext v, v; java.lang.Runnable v; java.util.concurrent.atomic.AtomicInteger v; java.lang.Thread v, v, v; java.time.Duration v; java.util.concurrent.ThreadFactory v, v; boolean v, v, v; java.util.concurrent.ConcurrentHashMap v; java.util.Set v; float v; java.util.concurrent.atomic.LongAdder v, v, v, v; org.jboss.threads.EnhancedQueueExecutor v; long v, v, v, v, v, v; org.jboss.threads.EnhancedQueueExecutor$MBeanRegisterAction v; java.lang.Thread$UncaughtExceptionHandler v; int v, v, v, v, v; java.lang.String v, v, v, v; java.util.concurrent.Executor v; org.jboss.threads.EnhancedQueueExecutor$MXBeanImpl v, v; org.jboss.threads.ContextHandler v; org.jboss.threads.EnhancedQueueExecutor$Builder v; java.lang.Object v; org.jboss.threads.EnhancedQueueExecutor$SchedulerTask v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: org.jboss.threads.EnhancedQueueExecutor$Builder; specialinvoke v.()>(); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v = staticinvoke (v); v. = v; v = new org.jboss.threads.EnhancedQueueExecutor$SchedulerTask; specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor)>(v); v. = v; v = new java.util.concurrent.atomic.LongAdder; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.LongAdder; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.LongAdder; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.LongAdder; specialinvoke v.()>(); v. = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; v = v.; v = v.; v = interfaceinvoke v.(v); v. = v; v = v.; v = virtualinvoke v.(); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u (scheduler)"); virtualinvoke v.(v); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (0L, v); v = staticinvoke (v, v); v = staticinvoke (v, v); v. = v; v = staticinvoke (v); v. = v; v = staticinvoke (0L, 0); v = virtualinvoke v.(); v = staticinvoke (v, v); v. = v; v = new org.jboss.threads.EnhancedQueueExecutor$MXBeanImpl; specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor)>(v); v. = v; v = ; if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (); v. = v; v = virtualinvoke v.(); if v == null goto label; v = v; goto label; label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("threadpool-\u0001"); label: v = new org.jboss.threads.EnhancedQueueExecutor$MBeanRegisterAction; v = v.; specialinvoke v.(java.lang.String,org.jboss.threads.EnhancedQueueExecutor$MXBeanImpl)>(v, v); v = v.; v = staticinvoke (v, v); v. = v; goto label; label: v. = null; v. = null; label: return; } public void execute(java.lang.Runnable) { java.lang.Throwable v; java.util.concurrent.atomic.LongAdder v, v; org.jboss.threads.EnhancedQueueExecutor v; long v; java.lang.AssertionError v; java.lang.Runnable v; int v, v, v; boolean v, v, v, v, v; org.jboss.threads.ContextHandler v; java.lang.Object v; org.jboss.threads.EnhancedQueueExecutor$Task v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.lang.Runnable; staticinvoke ("runnable", v); v = new org.jboss.threads.EnhancedQueueExecutor$Task; v = v.; v = interfaceinvoke v.(); specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor,java.lang.Runnable,java.lang.Object)>(v, v, v); v = specialinvoke v.(v); if v != 0 goto label; v = v.; v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(0.0F); if v != 0 goto label; v = virtualinvoke v.(null); if v != 0 goto label; virtualinvoke v.(); label: v = ; if v == 0 goto label; v = v.; virtualinvoke v.(); label: return; label: if v != 3 goto label; label: v = virtualinvoke v.(v); label: if v != 0 goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: v = ; if v == 0 goto label; v = v.; virtualinvoke v.(); label: if v != 2 goto label; virtualinvoke v.(v); goto label; label: v = ; if v != 0 goto label; if v == 1 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: virtualinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } public void shutdown() { org.jboss.threads.EnhancedQueueExecutor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; virtualinvoke v.(0); return; } public java.util.List shutdownNow() { org.jboss.threads.EnhancedQueueExecutor v; org.jboss.threads.EnhancedQueueExecutor$QNode v; org.jboss.threads.EnhancedQueueExecutor$TaskNode v; java.lang.Runnable v; java.util.ArrayList v; org.jboss.threads.EnhancedQueueExecutor$Task v; boolean v, v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; virtualinvoke v.(1); v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; label: v = virtualinvoke v.(); if v != v goto label; v = v.; goto label; label: v = v instanceof org.jboss.threads.EnhancedQueueExecutor$TaskNode; if v == 0 goto label; v = virtualinvoke v.(v, v); if v == 0 goto label; virtualinvoke v.(v); v = ; if v != 0 goto label; virtualinvoke v.(); label: v = v; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: return v; } public boolean isShutdown() { long v; org.jboss.threads.EnhancedQueueExecutor v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = staticinvoke (v); return v; } public boolean isTerminated() { long v; org.jboss.threads.EnhancedQueueExecutor v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = staticinvoke (v); return v; } public boolean awaitTermination(long, java.util.concurrent.TimeUnit) throws java.lang.InterruptedException { java.lang.Throwable v; java.lang.IllegalStateException v; org.jboss.threads.EnhancedQueueExecutor v; long v, v; byte v; java.lang.Thread v, v, v; org.jboss.threads.Waiter v, v, v, v; boolean v, v, v, v; java.util.Set v; java.util.concurrent.TimeUnit v; java.lang.InterruptedException v; org.jboss.threads.Messages v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; staticinvoke ("timeout", 0L, v); staticinvoke ("unit", v); v = v cmp 0L; if v <= 0 goto label; v = staticinvoke (); v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; v = v.; if v != v goto label; label: v = ; v = interfaceinvoke v.(); throw v; label: v = v.; v = ; if v != v goto label; return 1; label: v = new org.jboss.threads.Waiter; specialinvoke v.(org.jboss.threads.Waiter)>(v); v = staticinvoke (); virtualinvoke v.(v); label: v = virtualinvoke v.(v, v); if v != 0 goto label; v = v.; v = ; if v != v goto label; return 1; label: virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(v); staticinvoke (v, v); label: virtualinvoke v.(null); goto label; label: v := @caughtexception; virtualinvoke v.(null); throw v; label: v = staticinvoke (); if v == 0 goto label; v = new java.lang.InterruptedException; specialinvoke v.()>(); throw v; label: v = virtualinvoke v.(); return v; catch java.lang.Throwable from label to label with label; } public java.util.concurrent.ScheduledFuture schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v; org.jboss.threads.EnhancedQueueExecutor v; org.jboss.threads.EnhancedQueueExecutor$RunnableScheduledFuture v; org.jboss.threads.EnhancedQueueExecutor$AbstractScheduledFuture v; long v; java.lang.Runnable v; org.jboss.threads.EnhancedQueueExecutor$SchedulerTask v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.lang.Runnable; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; specialinvoke v.(); v = v.; v = new org.jboss.threads.EnhancedQueueExecutor$RunnableScheduledFuture; specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor,java.lang.Runnable,long,java.util.concurrent.TimeUnit)>(v, v, v, v); v = virtualinvoke v.(v); return v; } public java.util.concurrent.ScheduledFuture schedule(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v; org.jboss.threads.EnhancedQueueExecutor v; org.jboss.threads.EnhancedQueueExecutor$AbstractScheduledFuture v; org.jboss.threads.EnhancedQueueExecutor$CallableScheduledFuture v; java.util.concurrent.Callable v; long v; org.jboss.threads.EnhancedQueueExecutor$SchedulerTask v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.util.concurrent.Callable; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; specialinvoke v.(); v = v.; v = new org.jboss.threads.EnhancedQueueExecutor$CallableScheduledFuture; specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor,java.util.concurrent.Callable,long,java.util.concurrent.TimeUnit)>(v, v, v, v); v = virtualinvoke v.(v); return v; } public java.util.concurrent.ScheduledFuture scheduleAtFixedRate(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit) { org.jboss.threads.EnhancedQueueExecutor v; long v, v; java.lang.Runnable v; java.util.concurrent.TimeUnit v; org.jboss.threads.EnhancedQueueExecutor$AbstractScheduledFuture v; org.jboss.threads.EnhancedQueueExecutor$FixedRateRunnableScheduledFuture v; org.jboss.threads.EnhancedQueueExecutor$SchedulerTask v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.lang.Runnable; v := @parameter: long; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; specialinvoke v.(); v = v.; v = new org.jboss.threads.EnhancedQueueExecutor$FixedRateRunnableScheduledFuture; specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor,java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v, v); v = virtualinvoke v.(v); return v; } public java.util.concurrent.ScheduledFuture scheduleWithFixedDelay(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit) { org.jboss.threads.EnhancedQueueExecutor v; long v, v; java.lang.Runnable v; java.util.concurrent.TimeUnit v; org.jboss.threads.EnhancedQueueExecutor$AbstractScheduledFuture v; org.jboss.threads.EnhancedQueueExecutor$FixedDelayRunnableScheduledFuture v; org.jboss.threads.EnhancedQueueExecutor$SchedulerTask v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.lang.Runnable; v := @parameter: long; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; specialinvoke v.(); v = v.; v = new org.jboss.threads.EnhancedQueueExecutor$FixedDelayRunnableScheduledFuture; specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor,java.lang.Runnable,long,long,java.util.concurrent.TimeUnit)>(v, v, v, v, v); v = virtualinvoke v.(v); return v; } private void startScheduleThread() { java.lang.IllegalThreadStateException v; org.jboss.threads.EnhancedQueueExecutor v; java.lang.Thread$State v, v; java.lang.Thread v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; label: v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; label: return; catch java.lang.IllegalThreadStateException from label to label with label; } public org.jboss.threads.management.StandardThreadPoolMXBean getThreadPoolMXBean() { org.jboss.threads.EnhancedQueueExecutor v; org.jboss.threads.EnhancedQueueExecutor$MXBeanImpl v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; return v; } public void shutdown(boolean) { java.lang.IllegalStateException v; java.lang.Runnable v, v; byte v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Set v; org.jboss.threads.EnhancedQueueExecutor v; org.jboss.threads.EnhancedQueueExecutor$QNode v, v; long v, v; org.jboss.threads.EnhancedQueueExecutor$TaskNode v; java.lang.AssertionError v, v, v, v; int v; java.util.Iterator v; java.lang.Object v; org.jboss.threads.EnhancedQueueExecutor$SchedulerTask v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: boolean; label: v = v.; v = staticinvoke (v); if v == 0 goto label; v = staticinvoke (v); label: v = staticinvoke (v); if v != 0 goto label; v = staticinvoke (v); label: v = v cmp v; if v != 0 goto label; return; label: v = virtualinvoke v.(v, v); if v == 0 goto label; v = ; if v != 0 goto label; v = v cmp v; if v != 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = staticinvoke (v); v = staticinvoke (v); if v == v goto label; v = ; if v != 0 goto label; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = v.; virtualinvoke v.(); v = v.; label: v = virtualinvoke v.(); v = v instanceof org.jboss.threads.EnhancedQueueExecutor$TaskNode; if v != 0 goto label; v = v instanceof org.jboss.threads.EnhancedQueueExecutor$PoolThreadNode; if v != 0 goto label; if v != null goto label; label: v = ; v = virtualinvoke v.(v, v); if v == 0 goto label; label: if v == null goto label; v = ; v = ; virtualinvoke v.(v, v); virtualinvoke v.(); v = virtualinvoke v.(); goto label; label: v = v instanceof org.jboss.threads.EnhancedQueueExecutor$TerminateWaiterNode; if v != 0 goto label; v = staticinvoke (); throw v; label: v = staticinvoke (v); v = staticinvoke (v); if v == v goto label; v = ; if v != 0 goto label; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: v = staticinvoke (v); v = staticinvoke (v); if v == v goto label; v = ; if v != 0 goto label; v = staticinvoke (v); if v == 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: virtualinvoke v.(); label: return; } public boolean isTerminating() { org.jboss.threads.EnhancedQueueExecutor v; long v; boolean v, v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = staticinvoke (v); if v == 0 goto label; v = staticinvoke (v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public boolean prestartCoreThread() { int v; org.jboss.threads.EnhancedQueueExecutor v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = virtualinvoke v.(1.0F); if v == 0 goto label; return 0; label: v = virtualinvoke v.(null); if v == 0 goto label; return 1; label: virtualinvoke v.(); return 0; } public int prestartAllCoreThreads() { int v; org.jboss.threads.EnhancedQueueExecutor v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = 0; label: v = virtualinvoke v.(); if v == 0 goto label; v = v + 1; goto label; label: return v; } public float getGrowthResistance() { float v; org.jboss.threads.EnhancedQueueExecutor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; return v; } public void setGrowthResistance(float) { float v; org.jboss.threads.EnhancedQueueExecutor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: float; staticinvoke ("growthResistance", 0.0F, v); staticinvoke ("growthResistance", 1.0F, v); v. = v; return; } public int getCorePoolSize() { int v; long v; org.jboss.threads.EnhancedQueueExecutor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = staticinvoke (v); return v; } public void setCorePoolSize(int) { org.jboss.threads.EnhancedQueueExecutor v; java.util.Iterator v; java.util.Set v; long v, v, v; int v, v, v, v, v, v; java.lang.Object v; boolean v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: int; staticinvoke ("corePoolSize", 0, v); staticinvoke ("corePoolSize", 1048575L, v); label: v = v.; v = staticinvoke (v); if v <= v goto label; v = staticinvoke (v, v); v = staticinvoke (v, v); goto label; label: v = staticinvoke (v, v); label: v = virtualinvoke v.(v, v); if v == 0 goto label; v = staticinvoke (v); v = staticinvoke (v); if v < v goto label; v = staticinvoke (v); v = staticinvoke (v); if v >= v goto label; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); staticinvoke (v); goto label; label: return; } public int getMaximumPoolSize() { int v; long v; org.jboss.threads.EnhancedQueueExecutor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = staticinvoke (v); return v; } public void setMaximumPoolSize(int) { org.jboss.threads.EnhancedQueueExecutor v; java.util.Iterator v; java.util.Set v; long v, v, v; int v, v, v, v, v, v; java.lang.Object v; boolean v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: int; staticinvoke ("maxPoolSize", 0, v); staticinvoke ("maxPoolSize", 1048575L, v); label: v = v.; v = staticinvoke (v); if v >= v goto label; v = staticinvoke (v, v); v = staticinvoke (v, v); goto label; label: v = staticinvoke (v, v); label: v = virtualinvoke v.(v, v); if v == 0 goto label; v = staticinvoke (v); v = staticinvoke (v); if v < v goto label; v = staticinvoke (v); v = staticinvoke (v); if v >= v goto label; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); staticinvoke (v); goto label; label: return; } public boolean allowsCoreThreadTimeOut() { long v; org.jboss.threads.EnhancedQueueExecutor v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = staticinvoke (v); return v; } public void allowCoreThreadTimeOut(boolean) { org.jboss.threads.EnhancedQueueExecutor v; java.util.Iterator v; java.util.Set v; long v, v; byte v; java.lang.Object v; boolean v, v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: boolean; label: v = v.; v = staticinvoke (v, v); v = v cmp v; if v != 0 goto label; return; label: v = virtualinvoke v.(v, v); if v == 0 goto label; if v == 0 goto label; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); staticinvoke (v); goto label; label: return; } public long getKeepAliveTime(java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v, v; org.jboss.threads.EnhancedQueueExecutor v; long v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.util.concurrent.TimeUnit; staticinvoke ("keepAliveUnits", v); v = v.; v = ; v = virtualinvoke v.(v, v); return v; } public java.time.Duration getKeepAliveTime() { java.time.temporal.ChronoUnit v; org.jboss.threads.EnhancedQueueExecutor v; java.time.Duration v; long v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = ; v = staticinvoke (v, v); return v; } public void setKeepAliveTime(long, java.util.concurrent.TimeUnit) { java.util.concurrent.TimeUnit v; org.jboss.threads.EnhancedQueueExecutor v; long v, v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: long; v := @parameter: java.util.concurrent.TimeUnit; staticinvoke ("keepAliveTime", 1L, v); staticinvoke ("keepAliveUnits", v); v = virtualinvoke v.(v); v = staticinvoke (1L, v); v. = v; return; } public void setKeepAliveTime(java.time.Duration) { long v; org.jboss.threads.EnhancedQueueExecutor v; java.time.Duration v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.time.Duration; staticinvoke ("keepAliveTime", v); v = staticinvoke (v); v. = v; return; } public int getMaximumQueueSize() { int v; long v; org.jboss.threads.EnhancedQueueExecutor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = staticinvoke (v); return v; } public void setMaximumQueueSize(int) { org.jboss.threads.EnhancedQueueExecutor v; int v; long v, v; boolean v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: int; staticinvoke ("maxQueueSize", 0, v); staticinvoke ("maxQueueSize", 2147483647, v); v = ; if v == 0 goto label; return; label: v = v.; v = staticinvoke (v, v); v = virtualinvoke v.(v, v); if v == 0 goto label; return; } public java.util.concurrent.Executor getHandoffExecutor() { org.jboss.threads.EnhancedQueueExecutor v; java.util.concurrent.Executor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; return v; } public void setHandoffExecutor(java.util.concurrent.Executor) { org.jboss.threads.EnhancedQueueExecutor v; java.util.concurrent.Executor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.util.concurrent.Executor; staticinvoke ("handoffExecutor", v); v. = v; return; } public java.lang.Thread$UncaughtExceptionHandler getExceptionHandler() { org.jboss.threads.EnhancedQueueExecutor v; java.lang.Thread$UncaughtExceptionHandler v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; return v; } public void setExceptionHandler(java.lang.Thread$UncaughtExceptionHandler) { org.jboss.threads.EnhancedQueueExecutor v; java.lang.Thread$UncaughtExceptionHandler v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.lang.Thread$UncaughtExceptionHandler; staticinvoke ("exceptionHandler", v); v. = v; return; } public void setTerminationTask(java.lang.Runnable) { org.jboss.threads.EnhancedQueueExecutor v; java.lang.Runnable v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: java.lang.Runnable; v. = v; return; } public int getQueueSize() { org.jboss.threads.EnhancedQueueExecutor v; int v, v; long v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = ; if v == 0 goto label; v = (int) -1; v = v; goto label; label: v = v.; v = staticinvoke (v); label: return v; } public int getLargestPoolSize() { org.jboss.threads.EnhancedQueueExecutor v; int v, v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = ; if v == 0 goto label; v = v.; goto label; label: v = (int) -1; v = v; label: return v; } public int getActiveCount() { org.jboss.threads.EnhancedQueueExecutor v; int v, v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = ; if v == 0 goto label; v = v.; goto label; label: v = (int) -1; v = v; label: return v; } public int getLargestQueueSize() { org.jboss.threads.EnhancedQueueExecutor v; int v, v; boolean v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = ; if v == 0 goto label; v = ; if v != 0 goto label; v = v.; goto label; label: v = (int) -1; v = v; label: return v; } public long getSubmittedTaskCount() { java.util.concurrent.atomic.LongAdder v; org.jboss.threads.EnhancedQueueExecutor v; long v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = ; if v == 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = -1L; label: return v; } public long getRejectedTaskCount() { java.util.concurrent.atomic.LongAdder v; org.jboss.threads.EnhancedQueueExecutor v; long v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = ; if v == 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = -1L; label: return v; } public long getCompletedTaskCount() { java.util.concurrent.atomic.LongAdder v; org.jboss.threads.EnhancedQueueExecutor v; long v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = ; if v == 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = -1L; label: return v; } public int getPoolSize() { int v; long v; org.jboss.threads.EnhancedQueueExecutor v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = staticinvoke (v); return v; } public java.lang.Thread[] getRunningThreads() { java.lang.Object[] v; org.jboss.threads.EnhancedQueueExecutor v; java.lang.Thread[] v; java.util.Set v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = v.; v = ; v = interfaceinvoke v.(v); return v; } int tryAllocateThread(float) { java.util.concurrent.atomic.LongAdder v; org.jboss.threads.EnhancedQueueExecutor v; long v, v; byte v, v, v; java.util.concurrent.ThreadLocalRandom v; int v, v, v, v, v; boolean v, v, v, v, v; float v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: float; label: v = v.; v = staticinvoke (v); if v == 0 goto label; return 2; label: v = staticinvoke (v); v = staticinvoke (v); if v < v goto label; return 1; label: v = staticinvoke (v); if v < v goto label; if v <= 0 goto label; v = v cmpl 0.0F; if v == 0 goto label; v = v cmpl 1.0F; if v == 0 goto label; v = staticinvoke (); v = virtualinvoke v.(); v = v cmpg v; if v >= 0 goto label; label: return 1; label: v = v + 1; v = staticinvoke (v, v); v = virtualinvoke v.(v, v); if v == 0 goto label; v = ; if v == 0 goto label; label: v = v.; if v >= v goto label; v = virtualinvoke v.(v, v); if v == 0 goto label; label: return 0; label: v = ; if v == 0 goto label; v = v.; virtualinvoke v.(); goto label; } void deallocateThread() { long v; org.jboss.threads.EnhancedQueueExecutor v; boolean v; v := @this: org.jboss.threads.EnhancedQueueExecutor; label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; return; } boolean tryDeallocateThread(long) { org.jboss.threads.EnhancedQueueExecutor v; long v, v; int v, v, v; boolean v, v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: long; v = staticinvoke (v); v = v - 1; v = staticinvoke (v, v); v = staticinvoke (v); if v != 0 goto label; v = staticinvoke (v); if v == 0 goto label; v = staticinvoke (v); label: v = virtualinvoke v.(v, v); if v != 0 goto label; return 0; label: v = staticinvoke (v); if v == 0 goto label; virtualinvoke v.(); label: return 1; } boolean doStartThread(org.jboss.threads.EnhancedQueueExecutor$Task) throws java.util.concurrent.RejectedExecutionException { java.lang.Throwable v, v; java.util.concurrent.atomic.LongAdder v, v, v; org.jboss.threads.EnhancedQueueExecutor v; org.jboss.threads.EnhancedQueueExecutor$ThreadBody v; java.lang.Thread v; org.jboss.threads.EnhancedQueueExecutor$Task v; java.util.concurrent.ThreadFactory v; boolean v, v, v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: org.jboss.threads.EnhancedQueueExecutor$Task; label: v = v.; v = new org.jboss.threads.EnhancedQueueExecutor$ThreadBody; specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor,org.jboss.threads.EnhancedQueueExecutor$Task)>(v, v); v = interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; if v == null goto label; v = ; if v == 0 goto label; v = v.; virtualinvoke v.(); label: virtualinvoke v.(v, v); label: return 0; label: if v != null goto label; if v == null goto label; v = ; if v == 0 goto label; v = v.; virtualinvoke v.(); label: virtualinvoke v.(v); label: return 0; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; if v == null goto label; v = ; if v == 0 goto label; v = v.; virtualinvoke v.(); label: virtualinvoke v.(v, v); label: return 0; label: return 1; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private int tryExecute(org.jboss.threads.EnhancedQueueExecutor$Task) { java.lang.Runnable v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; float v; java.util.concurrent.atomic.LongAdder v; org.jboss.threads.EnhancedQueueExecutor v; org.jboss.threads.EnhancedQueueExecutor$QNode v, v; org.jboss.threads.EnhancedQueueExecutor$TaskNode v, v, v; java.lang.AssertionError v, v, v, v; int v, v; org.jboss.threads.EnhancedQueueExecutor$Task v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v := @parameter: org.jboss.threads.EnhancedQueueExecutor$Task; v = v.; v = null; label: v = virtualinvoke v.(); if v == v goto label; if v != null goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; return 3; label: if v != 2 goto label; return 2; label: v = ; if v != 0 goto label; if v == 1 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = ; if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(0.0F); if v != 0 goto label; return 3; label: if v != 2 goto label; return 2; label: v = ; if v != 0 goto label; if v == 1 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: return 1; label: if v != null goto label; v = new org.jboss.threads.EnhancedQueueExecutor$TaskNode; specialinvoke v.(org.jboss.threads.EnhancedQueueExecutor$Task)>(v); v = v; label: v = virtualinvoke v.(null, v); if v == 0 goto label; virtualinvoke v.(v, v); return 0; label: v = ; if v != 0 goto label; virtualinvoke v.(); goto label; label: v = v instanceof org.jboss.threads.EnhancedQueueExecutor$PoolThreadNode; if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == 0 goto label; v = ; if v != 0 goto label; v = v instanceof org.jboss.threads.EnhancedQueueExecutor$TaskNode; if v != 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: v = ; v = virtualinvoke v.(v, v); if v == 0 goto label; virtualinvoke v.(v, null); virtualinvoke v.(); return 0; label: v = v instanceof org.jboss.threads.EnhancedQueueExecutor$TaskNode; if v == 0 goto label; v = virtualinvoke v.(v, v); if v == 0 goto label; v = v; goto label; label: v = ; if v != 0 goto label; v = v instanceof org.jboss.threads.EnhancedQueueExecutor$TerminateWaiterNode; if v != 0 goto label; v = new java.lang.AssertionError; specialinvoke v.()>(); throw v; label: return 2; label: v = ; if v == 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; goto label; } void completeTermination() { java.lang.Throwable v, v, v; java.security.AccessControlContext v, v; org.jboss.threads.EnhancedQueueExecutor v; org.jboss.threads.EnhancedQueueExecutor$QNode v; org.jboss.threads.EnhancedQueueExecutor$TaskNode v; java.lang.Runnable v, v; java.lang.Thread$UncaughtExceptionHandler v; java.lang.Thread v, v, v, v; org.jboss.threads.Waiter v, v; boolean v, v, v, v; org.jboss.threads.EnhancedQueueExecutor$MBeanUnregisterAction v; java.lang.Object v; v := @this: org.jboss.threads.EnhancedQueueExecutor; v = staticinvoke (); label: v = v.; v = staticinvoke (v); v. = null; label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; label: v = v.; v = staticinvoke (); interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; label: v = ; v = virtualinvoke v.(v); label: if v == null goto label; v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); goto label; label: v = v.; v = ; virtualinvoke v.(v); v = ; if v != 0 goto label; v = v.; if v == null goto label; v = v.