public class org.apache.camel.impl.DefaultThreadPoolFactory extends java.lang.Object implements org.apache.camel.spi.ThreadPoolFactory
{
public void <init>()
{
org.apache.camel.impl.DefaultThreadPoolFactory v;
v := @this: org.apache.camel.impl.DefaultThreadPoolFactory;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public java.util.concurrent.ExecutorService newCachedThreadPool(java.util.concurrent.ThreadFactory)
{
org.apache.camel.impl.DefaultThreadPoolFactory v;
java.util.concurrent.ThreadFactory v;
java.util.concurrent.ExecutorService v;
v := @this: org.apache.camel.impl.DefaultThreadPoolFactory;
v := @parameter: java.util.concurrent.ThreadFactory;
v = staticinvoke <java.util.concurrent.Executors: java.util.concurrent.ExecutorService newCachedThreadPool(java.util.concurrent.ThreadFactory)>(v);
return v;
}
public java.util.concurrent.ExecutorService newThreadPool(org.apache.camel.spi.ThreadPoolProfile, java.util.concurrent.ThreadFactory)
{
org.apache.camel.spi.ThreadPoolProfile v;
long v;
java.lang.Integer v, v, v;
java.lang.Long v;
java.util.concurrent.RejectedExecutionHandler v;
int v, v, v;
java.lang.Boolean v, v;
java.util.concurrent.ThreadFactory v;
java.util.concurrent.ExecutorService v;
boolean v;
java.util.concurrent.TimeUnit v;
org.apache.camel.impl.DefaultThreadPoolFactory v;
v := @this: org.apache.camel.impl.DefaultThreadPoolFactory;
v := @parameter: org.apache.camel.spi.ThreadPoolProfile;
v := @parameter: java.util.concurrent.ThreadFactory;
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Boolean getAllowCoreThreadTimeOut()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Boolean getAllowCoreThreadTimeOut()>();
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
goto label;
label:
v = 0;
label:
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Integer getPoolSize()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Integer getMaxPoolSize()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Long getKeepAliveTime()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.util.concurrent.TimeUnit getTimeUnit()>();
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Integer getMaxQueueSize()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()>();
v = virtualinvoke v.<org.apache.camel.impl.DefaultThreadPoolFactory: java.util.concurrent.ExecutorService newThreadPool(int,int,long,java.util.concurrent.TimeUnit,int,boolean,java.util.concurrent.RejectedExecutionHandler,java.util.concurrent.ThreadFactory)>(v, v, v, v, v, v, v, v);
return v;
}
public java.util.concurrent.ExecutorService newThreadPool(int, int, long, java.util.concurrent.TimeUnit, int, boolean, java.util.concurrent.RejectedExecutionHandler, java.util.concurrent.ThreadFactory) throws java.lang.IllegalArgumentException
{
java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy v;
long v;
org.apache.camel.util.concurrent.RejectableThreadPoolExecutor v;
java.util.concurrent.RejectedExecutionHandler v;
int v, v, v;
java.lang.String v, v;
java.util.concurrent.ThreadFactory v;
boolean v;
java.util.concurrent.SynchronousQueue v, v;
java.util.concurrent.BlockingQueue v;
java.lang.IllegalArgumentException v, v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.concurrent.TimeUnit v;
org.apache.camel.impl.DefaultThreadPoolFactory v;
v := @this: org.apache.camel.impl.DefaultThreadPoolFactory;
v := @parameter: int;
v := @parameter: int;
v := @parameter: long;
v := @parameter: java.util.concurrent.TimeUnit;
v := @parameter: int;
v := @parameter: boolean;
v := @parameter: java.util.concurrent.RejectedExecutionHandler;
v := @parameter: java.util.concurrent.ThreadFactory;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("CorePoolSize must be >= 0, was \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
if v >= v goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(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[])>("MaxPoolSize must be >= corePoolSize, was \u >= \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
if v != 0 goto label;
if v > 0 goto label;
v = new java.util.concurrent.SynchronousQueue;
specialinvoke v.<java.util.concurrent.SynchronousQueue: void <init>()>();
v = v;
v = 1;
v = 1;
goto label;
label:
if v > 0 goto label;
v = new java.util.concurrent.SynchronousQueue;
specialinvoke v.<java.util.concurrent.SynchronousQueue: void <init>()>();
v = v;
goto label;
label:
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>(int)>(v);
v = v;
label:
v = new org.apache.camel.util.concurrent.RejectableThreadPoolExecutor;
specialinvoke v.<org.apache.camel.util.concurrent.RejectableThreadPoolExecutor: void <init>(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue)>(v, v, v, v, v);
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: void setThreadFactory(java.util.concurrent.ThreadFactory)>(v);
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: void allowCoreThreadTimeOut(boolean)>(v);
if v != null goto label;
v = new java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy;
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy: void <init>()>();
v = v;
label:
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler)>(v);
return v;
}
public java.util.concurrent.ScheduledExecutorService newScheduledThreadPool(org.apache.camel.spi.ThreadPoolProfile, java.util.concurrent.ThreadFactory)
{
java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy v;
org.apache.camel.spi.ThreadPoolProfile v;
java.lang.Integer v, v, v;
org.apache.camel.util.concurrent.RejectableScheduledThreadPoolExecutor v;
org.apache.camel.impl.DefaultThreadPoolFactory v;
java.util.concurrent.RejectedExecutionHandler v;
int v, v, v;
java.util.concurrent.ThreadFactory v;
org.apache.camel.util.concurrent.SizedScheduledExecutorService v;
v := @this: org.apache.camel.impl.DefaultThreadPoolFactory;
v := @parameter: org.apache.camel.spi.ThreadPoolProfile;
v := @parameter: java.util.concurrent.ThreadFactory;
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.util.concurrent.RejectedExecutionHandler getRejectedExecutionHandler()>();
if v != null goto label;
v = new java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy;
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy: void <init>()>();
v = v;
label:
v = new org.apache.camel.util.concurrent.RejectableScheduledThreadPoolExecutor;
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Integer getPoolSize()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
specialinvoke v.<org.apache.camel.util.concurrent.RejectableScheduledThreadPoolExecutor: void <init>(int,java.util.concurrent.ThreadFactory,java.util.concurrent.RejectedExecutionHandler)>(v, v, v);
virtualinvoke v.<java.util.concurrent.ScheduledThreadPoolExecutor: void setRemoveOnCancelPolicy(boolean)>(1);
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Integer getMaxPoolSize()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
if v <= 0 goto label;
v = new org.apache.camel.util.concurrent.SizedScheduledExecutorService;
v = virtualinvoke v.<org.apache.camel.spi.ThreadPoolProfile: java.lang.Integer getMaxQueueSize()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
specialinvoke v.<org.apache.camel.util.concurrent.SizedScheduledExecutorService: void <init>(java.util.concurrent.ScheduledThreadPoolExecutor,long)>(v, v);
return v;
label:
return v;
}
}