public class org.linkedin.util.concurrent.ThreadPerTaskExecutor extends java.lang.Object implements java.util.concurrent.Executor
{
private final java.util.concurrent.ThreadFactory _threadFactory;
public void <init>()
{
org.linkedin.util.concurrent.ThreadPerTaskExecutor$1 v;
org.linkedin.util.concurrent.ThreadPerTaskExecutor v;
v := @this: org.linkedin.util.concurrent.ThreadPerTaskExecutor;
v = new org.linkedin.util.concurrent.ThreadPerTaskExecutor$1;
specialinvoke v.<org.linkedin.util.concurrent.ThreadPerTaskExecutor$1: void <init>()>();
specialinvoke v.<org.linkedin.util.concurrent.ThreadPerTaskExecutor: void <init>(java.util.concurrent.ThreadFactory)>(v);
return;
}
public void <init>(java.util.concurrent.ThreadFactory)
{
java.util.concurrent.ThreadFactory v;
org.linkedin.util.concurrent.ThreadPerTaskExecutor v;
v := @this: org.linkedin.util.concurrent.ThreadPerTaskExecutor;
v := @parameter: java.util.concurrent.ThreadFactory;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.linkedin.util.concurrent.ThreadPerTaskExecutor: java.util.concurrent.ThreadFactory _threadFactory> = v;
return;
}
public void execute(java.lang.Runnable)
{
java.lang.Thread v;
org.linkedin.util.concurrent.ThreadPerTaskExecutor v;
java.util.concurrent.ThreadFactory v;
java.lang.Runnable v;
v := @this: org.linkedin.util.concurrent.ThreadPerTaskExecutor;
v := @parameter: java.lang.Runnable;
v = v.<org.linkedin.util.concurrent.ThreadPerTaskExecutor: java.util.concurrent.ThreadFactory _threadFactory>;
v = interfaceinvoke v.<java.util.concurrent.ThreadFactory: java.lang.Thread newThread(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
return;
}
public static java.util.concurrent.Future execute(java.util.concurrent.Callable)
{
java.util.concurrent.FutureTask v;
java.util.concurrent.Callable v;
java.lang.Thread v;
v := @parameter: java.util.concurrent.Callable;
v = new java.util.concurrent.FutureTask;
specialinvoke v.<java.util.concurrent.FutureTask: void <init>(java.util.concurrent.Callable)>(v);
v = new java.lang.Thread;
specialinvoke v.<java.lang.Thread: void <init>(java.lang.Runnable)>(v);
virtualinvoke v.<java.lang.Thread: void start()>();
return v;
}
}