class io.vertx.core.impl.WorkerExecutorImpl extends java.lang.Object implements io.vertx.core.spi.metrics.MetricsProvider, io.vertx.core.impl.WorkerExecutorInternal
{
private final io.vertx.core.impl.VertxInternal vertx;
private final io.vertx.core.impl.CloseFuture closeFuture;
private final io.vertx.core.impl.VertxImpl$SharedWorkerPool pool;
private boolean closed;
public void <init>(io.vertx.core.impl.VertxInternal, io.vertx.core.impl.CloseFuture, io.vertx.core.impl.VertxImpl$SharedWorkerPool)
{
io.vertx.core.impl.VertxInternal v;
io.vertx.core.impl.WorkerExecutorImpl v;
io.vertx.core.impl.CloseFuture v;
io.vertx.core.impl.VertxImpl$SharedWorkerPool v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v := @parameter: io.vertx.core.impl.VertxInternal;
v := @parameter: io.vertx.core.impl.CloseFuture;
v := @parameter: io.vertx.core.impl.VertxImpl$SharedWorkerPool;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxInternal vertx> = v;
v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.CloseFuture closeFuture> = v;
v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxImpl$SharedWorkerPool pool> = v;
return;
}
public io.vertx.core.spi.metrics.Metrics getMetrics()
{
io.vertx.core.impl.VertxImpl$SharedWorkerPool v;
io.vertx.core.spi.metrics.PoolMetrics v;
io.vertx.core.impl.WorkerExecutorImpl v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxImpl$SharedWorkerPool pool>;
v = virtualinvoke v.<io.vertx.core.impl.VertxImpl$SharedWorkerPool: io.vertx.core.spi.metrics.PoolMetrics metrics()>();
return v;
}
public boolean isMetricsEnabled()
{
io.vertx.core.spi.metrics.PoolMetrics v;
io.vertx.core.impl.WorkerExecutorImpl v;
io.vertx.core.impl.VertxImpl$SharedWorkerPool v;
boolean v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxImpl$SharedWorkerPool pool>;
v = virtualinvoke v.<io.vertx.core.impl.VertxImpl$SharedWorkerPool: io.vertx.core.spi.metrics.PoolMetrics metrics()>();
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public io.vertx.core.Vertx vertx()
{
io.vertx.core.impl.VertxInternal v;
io.vertx.core.impl.WorkerExecutorImpl v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxInternal vertx>;
return v;
}
public io.vertx.core.impl.WorkerPool getPool()
{
io.vertx.core.impl.VertxImpl$SharedWorkerPool v;
io.vertx.core.impl.WorkerExecutorImpl v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxImpl$SharedWorkerPool pool>;
return v;
}
public io.vertx.core.Future executeBlocking(io.vertx.core.Handler, boolean)
{
java.lang.Throwable v;
java.lang.IllegalStateException v;
io.vertx.core.impl.VertxInternal v;
io.vertx.core.impl.WorkerExecutorImpl v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Future v;
io.vertx.core.impl.ContextBase v;
io.vertx.core.impl.TaskQueue v;
io.vertx.core.impl.VertxImpl$SharedWorkerPool v;
io.vertx.core.Handler v;
boolean v, v, v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v := @parameter: io.vertx.core.Handler;
v := @parameter: boolean;
entermonitor v;
label:
v = v.<io.vertx.core.impl.WorkerExecutorImpl: boolean closed>;
if v == 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Worker executor closed");
throw v;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxInternal vertx>;
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: io.vertx.core.impl.ContextInternal getOrCreateContext()>();
v = v instanceof io.vertx.core.impl.DuplicatedContext;
if v == 0 goto label;
v = v.<io.vertx.core.impl.DuplicatedContext: io.vertx.core.impl.ContextBase delegate>;
label:
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxImpl$SharedWorkerPool pool>;
if v == 0 goto label;
v = v.<io.vertx.core.impl.ContextBase: io.vertx.core.impl.TaskQueue orderedTasks>;
goto label;
label:
v = null;
label:
v = staticinvoke <io.vertx.core.impl.ContextBase: io.vertx.core.Future executeBlocking(io.vertx.core.impl.ContextInternal,io.vertx.core.Handler,io.vertx.core.impl.WorkerPool,io.vertx.core.impl.TaskQueue)>(v, v, v, v);
return v;
catch java.lang.Throwable from label to label with label;
}
public io.vertx.core.Future executeBlocking(java.util.concurrent.Callable, boolean)
{
io.vertx.core.impl.VertxInternal v;
io.vertx.core.impl.WorkerExecutorImpl v;
io.vertx.core.impl.ContextInternal v;
java.util.concurrent.Callable v;
io.vertx.core.Future v;
io.vertx.core.impl.ContextBase v;
io.vertx.core.impl.TaskQueue v;
io.vertx.core.impl.VertxImpl$SharedWorkerPool v;
boolean v, v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v := @parameter: java.util.concurrent.Callable;
v := @parameter: boolean;
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxInternal vertx>;
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: io.vertx.core.impl.ContextInternal getOrCreateContext()>();
v = v instanceof io.vertx.core.impl.DuplicatedContext;
if v == 0 goto label;
v = v.<io.vertx.core.impl.DuplicatedContext: io.vertx.core.impl.ContextBase delegate>;
label:
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxImpl$SharedWorkerPool pool>;
if v == 0 goto label;
v = v.<io.vertx.core.impl.ContextBase: io.vertx.core.impl.TaskQueue orderedTasks>;
goto label;
label:
v = null;
label:
v = staticinvoke <io.vertx.core.impl.ContextBase: io.vertx.core.Future executeBlocking(io.vertx.core.impl.ContextInternal,java.util.concurrent.Callable,io.vertx.core.impl.WorkerPool,io.vertx.core.impl.TaskQueue)>(v, v, v, v);
return v;
}
public void executeBlocking(io.vertx.core.Handler, boolean, io.vertx.core.Handler)
{
io.vertx.core.impl.WorkerExecutorImpl v;
io.vertx.core.Handler v, v;
io.vertx.core.Future v;
boolean v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v := @parameter: io.vertx.core.Handler;
v := @parameter: boolean;
v := @parameter: io.vertx.core.Handler;
v = virtualinvoke v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.Future executeBlocking(io.vertx.core.Handler,boolean)>(v, v);
if v == null goto label;
interfaceinvoke v.<io.vertx.core.Future: io.vertx.core.Future onComplete(io.vertx.core.Handler)>(v);
label:
return;
}
public io.vertx.core.Future close()
{
io.vertx.core.impl.VertxInternal v;
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.impl.WorkerExecutorImpl v;
io.vertx.core.impl.CloseFuture v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Future v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxInternal vertx>;
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: io.vertx.core.impl.ContextInternal getOrCreateContext()>();
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise()>();
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.CloseFuture closeFuture>;
virtualinvoke v.<io.vertx.core.impl.CloseFuture: void close(io.vertx.core.Promise)>(v);
v = interfaceinvoke v.<io.vertx.core.impl.future.PromiseInternal: io.vertx.core.Future future()>();
return v;
}
public void close(io.vertx.core.Handler)
{
io.vertx.core.impl.VertxInternal v;
io.vertx.core.impl.future.PromiseInternal v;
io.vertx.core.impl.WorkerExecutorImpl v;
io.vertx.core.impl.CloseFuture v;
io.vertx.core.impl.ContextInternal v;
io.vertx.core.Handler v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v := @parameter: io.vertx.core.Handler;
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxInternal vertx>;
v = interfaceinvoke v.<io.vertx.core.impl.VertxInternal: io.vertx.core.impl.ContextInternal getOrCreateContext()>();
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.CloseFuture closeFuture>;
if v == null goto label;
v = interfaceinvoke v.<io.vertx.core.impl.ContextInternal: io.vertx.core.impl.future.PromiseInternal promise(io.vertx.core.Handler)>(v);
goto label;
label:
v = null;
label:
virtualinvoke v.<io.vertx.core.impl.CloseFuture: void close(io.vertx.core.Promise)>(v);
return;
}
public void close(io.vertx.core.Promise)
{
java.lang.Throwable v;
io.vertx.core.impl.WorkerExecutorImpl v;
io.vertx.core.Promise v;
io.vertx.core.impl.VertxImpl$SharedWorkerPool v;
v := @this: io.vertx.core.impl.WorkerExecutorImpl;
v := @parameter: io.vertx.core.Promise;
entermonitor v;
label:
v.<io.vertx.core.impl.WorkerExecutorImpl: boolean closed> = 1;
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v.<io.vertx.core.impl.WorkerExecutorImpl: io.vertx.core.impl.VertxImpl$SharedWorkerPool pool>;
virtualinvoke v.<io.vertx.core.impl.VertxImpl$SharedWorkerPool: void close()>();
interfaceinvoke v.<io.vertx.core.Promise: void complete()>();
return;
catch java.lang.Throwable from label to label with label;
}
}