public class io.vertx.core.impl.WorkerPool extends java.lang.Object
{
private final java.util.concurrent.ExecutorService pool;
private final io.vertx.core.spi.metrics.PoolMetrics metrics;
public void <init>(java.util.concurrent.ExecutorService, io.vertx.core.spi.metrics.PoolMetrics)
{
io.vertx.core.spi.metrics.PoolMetrics v;
io.vertx.core.impl.WorkerPool v;
java.util.concurrent.ExecutorService v;
v := @this: io.vertx.core.impl.WorkerPool;
v := @parameter: java.util.concurrent.ExecutorService;
v := @parameter: io.vertx.core.spi.metrics.PoolMetrics;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<io.vertx.core.impl.WorkerPool: java.util.concurrent.ExecutorService pool> = v;
v.<io.vertx.core.impl.WorkerPool: io.vertx.core.spi.metrics.PoolMetrics metrics> = v;
return;
}
public java.util.concurrent.ExecutorService executor()
{
io.vertx.core.impl.WorkerPool v;
java.util.concurrent.ExecutorService v;
v := @this: io.vertx.core.impl.WorkerPool;
v = v.<io.vertx.core.impl.WorkerPool: java.util.concurrent.ExecutorService pool>;
return v;
}
public io.vertx.core.spi.metrics.PoolMetrics metrics()
{
io.vertx.core.spi.metrics.PoolMetrics v;
io.vertx.core.impl.WorkerPool v;
v := @this: io.vertx.core.impl.WorkerPool;
v = v.<io.vertx.core.impl.WorkerPool: io.vertx.core.spi.metrics.PoolMetrics metrics>;
return v;
}
void close()
{
io.vertx.core.spi.metrics.PoolMetrics v, v;
io.vertx.core.impl.WorkerPool v;
java.util.concurrent.ExecutorService v;
v := @this: io.vertx.core.impl.WorkerPool;
v = v.<io.vertx.core.impl.WorkerPool: io.vertx.core.spi.metrics.PoolMetrics metrics>;
if v == null goto label;
v = v.<io.vertx.core.impl.WorkerPool: io.vertx.core.spi.metrics.PoolMetrics metrics>;
interfaceinvoke v.<io.vertx.core.spi.metrics.PoolMetrics: void close()>();
label:
v = v.<io.vertx.core.impl.WorkerPool: java.util.concurrent.ExecutorService pool>;
interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.List shutdownNow()>();
return;
}
}