public final class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ThreadPerTaskExecutor extends java.lang.Object implements java.util.concurrent.Executor
{
private final java.util.concurrent.ThreadFactory threadFactory;
public void <init>(java.util.concurrent.ThreadFactory)
{
java.lang.Object v;
java.util.concurrent.ThreadFactory v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ThreadPerTaskExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ThreadPerTaskExecutor;
v := @parameter: java.util.concurrent.ThreadFactory;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "threadFactory");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ThreadPerTaskExecutor: java.util.concurrent.ThreadFactory threadFactory> = v;
return;
}
public void execute(java.lang.Runnable)
{
java.lang.Thread v;
java.util.concurrent.ThreadFactory v;
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ThreadPerTaskExecutor v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.ThreadPerTaskExecutor;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.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;
}
}