public class org.apache.sling.event.impl.EventingThreadPool extends java.lang.Object implements org.apache.sling.commons.threads.ThreadPool
{
private org.apache.sling.commons.threads.ThreadPoolManager threadPoolManager;
private org.apache.sling.commons.threads.ThreadPool threadPool;
public void <init>()
{
org.apache.sling.event.impl.EventingThreadPool v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void <init>(org.apache.sling.commons.threads.ThreadPoolManager, int)
{
int v;
org.apache.sling.event.impl.EventingThreadPool v;
org.apache.sling.commons.threads.ThreadPoolManager v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
v := @parameter: org.apache.sling.commons.threads.ThreadPoolManager;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.sling.event.impl.EventingThreadPool: org.apache.sling.commons.threads.ThreadPoolManager threadPoolManager> = v;
specialinvoke v.<org.apache.sling.event.impl.EventingThreadPool: void configure(int)>(v);
return;
}
public void release()
{
org.apache.sling.event.impl.EventingThreadPool v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
virtualinvoke v.<org.apache.sling.event.impl.EventingThreadPool: void deactivate()>();
return;
}
protected void activate(org.apache.sling.event.impl.EventingThreadPool$Config)
{
int v;
org.apache.sling.event.impl.EventingThreadPool v;
org.apache.sling.event.impl.EventingThreadPool$Config v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
v := @parameter: org.apache.sling.event.impl.EventingThreadPool$Config;
v = interfaceinvoke v.<org.apache.sling.event.impl.EventingThreadPool$Config: int minPoolSize()>();
specialinvoke v.<org.apache.sling.event.impl.EventingThreadPool: void configure(int)>(v);
return;
}
private void configure(int)
{
org.apache.sling.commons.threads.ModifiableThreadPoolConfig v;
org.apache.sling.commons.threads.ThreadPoolManager v;
org.apache.sling.commons.threads.ThreadPoolConfig$ThreadPriority v;
int v, v, v;
org.apache.sling.commons.threads.ThreadPool v;
org.apache.sling.event.impl.EventingThreadPool v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
v := @parameter: int;
v = new org.apache.sling.commons.threads.ModifiableThreadPoolConfig;
specialinvoke v.<org.apache.sling.commons.threads.ModifiableThreadPoolConfig: void <init>()>();
virtualinvoke v.<org.apache.sling.commons.threads.ModifiableThreadPoolConfig: void setMinPoolSize(int)>(v);
v = virtualinvoke v.<org.apache.sling.commons.threads.ModifiableThreadPoolConfig: int getMinPoolSize()>();
virtualinvoke v.<org.apache.sling.commons.threads.ModifiableThreadPoolConfig: void setMaxPoolSize(int)>(v);
v = (int) -1;
virtualinvoke v.<org.apache.sling.commons.threads.ModifiableThreadPoolConfig: void setQueueSize(int)>(v);
virtualinvoke v.<org.apache.sling.commons.threads.ModifiableThreadPoolConfig: void setShutdownGraceful(boolean)>(1);
v = <org.apache.sling.commons.threads.ThreadPoolConfig$ThreadPriority: org.apache.sling.commons.threads.ThreadPoolConfig$ThreadPriority NORM>;
virtualinvoke v.<org.apache.sling.commons.threads.ModifiableThreadPoolConfig: void setPriority(org.apache.sling.commons.threads.ThreadPoolConfig$ThreadPriority)>(v);
virtualinvoke v.<org.apache.sling.commons.threads.ModifiableThreadPoolConfig: void setDaemon(boolean)>(1);
v = v.<org.apache.sling.event.impl.EventingThreadPool: org.apache.sling.commons.threads.ThreadPoolManager threadPoolManager>;
v = interfaceinvoke v.<org.apache.sling.commons.threads.ThreadPoolManager: org.apache.sling.commons.threads.ThreadPool create(org.apache.sling.commons.threads.ThreadPoolConfig,java.lang.String)>(v, "Apache Sling Job Thread Pool");
v.<org.apache.sling.event.impl.EventingThreadPool: org.apache.sling.commons.threads.ThreadPool threadPool> = v;
return;
}
protected void deactivate()
{
org.apache.sling.commons.threads.ThreadPool v;
org.apache.sling.event.impl.EventingThreadPool v;
org.apache.sling.commons.threads.ThreadPoolManager v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
v = v.<org.apache.sling.event.impl.EventingThreadPool: org.apache.sling.commons.threads.ThreadPoolManager threadPoolManager>;
v = v.<org.apache.sling.event.impl.EventingThreadPool: org.apache.sling.commons.threads.ThreadPool threadPool>;
interfaceinvoke v.<org.apache.sling.commons.threads.ThreadPoolManager: void release(org.apache.sling.commons.threads.ThreadPool)>(v);
return;
}
public void execute(java.lang.Runnable)
{
org.apache.sling.commons.threads.ThreadPool v;
org.apache.sling.event.impl.EventingThreadPool v;
java.lang.Runnable v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.sling.event.impl.EventingThreadPool: org.apache.sling.commons.threads.ThreadPool threadPool>;
interfaceinvoke v.<org.apache.sling.commons.threads.ThreadPool: void execute(java.lang.Runnable)>(v);
return;
}
public org.apache.sling.commons.threads.ThreadPoolConfig getConfiguration()
{
org.apache.sling.commons.threads.ThreadPool v;
org.apache.sling.event.impl.EventingThreadPool v;
org.apache.sling.commons.threads.ThreadPoolConfig v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
v = v.<org.apache.sling.event.impl.EventingThreadPool: org.apache.sling.commons.threads.ThreadPool threadPool>;
v = interfaceinvoke v.<org.apache.sling.commons.threads.ThreadPool: org.apache.sling.commons.threads.ThreadPoolConfig getConfiguration()>();
return v;
}
public java.lang.String getName()
{
org.apache.sling.commons.threads.ThreadPool v;
org.apache.sling.event.impl.EventingThreadPool v;
java.lang.String v;
v := @this: org.apache.sling.event.impl.EventingThreadPool;
v = v.<org.apache.sling.event.impl.EventingThreadPool: org.apache.sling.commons.threads.ThreadPool threadPool>;
v = interfaceinvoke v.<org.apache.sling.commons.threads.ThreadPool: java.lang.String getName()>();
return v;
}
}