package io.vertx.core.impl;
import io.vertx.core.Handler;
import io.vertx.core.json.JsonObject;
class MultiThreadedWorkerContext extends WorkerContext {
MultiThreadedWorkerContext(VertxInternal vertx, WorkerPool internalBlockingPool, WorkerPool workerPool,
String deploymentID, JsonObject config, ClassLoader tccl) {
super(vertx, internalBlockingPool, workerPool, deploymentID, config, tccl);
}
@Override
<T> void execute(T value, Handler<T> task) {
workerPool.executor().execute(wrapTask(value, task, workerPool.metrics()));
}
@Override
public boolean isMultiThreadedWorkerContext() {
return true;
}
}