diff options
| author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-09-28 14:18:02 +0200 |
|---|---|---|
| committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-09-28 14:19:38 +0200 |
| commit | 0cf64bbf1ce25a077b82d8262c7e0fe89bd4b172 (patch) | |
| tree | 0888d49a0658cb322b1c7ff2476e810655ec2d0f /container-core | |
| parent | cef539adea8b1ad6ba2314722c699a0a412082b7 (diff) | |
Provide underlying executor through getter
Diffstat (limited to 'container-core')
| -rw-r--r-- | container-core/abi-spec.json | 3 | ||||
| -rw-r--r-- | container-core/src/main/java/com/yahoo/container/jdisc/ThreadedRequestHandler.java | 2 |
2 files changed, 4 insertions, 1 deletions
diff --git a/container-core/abi-spec.json b/container-core/abi-spec.json index 28aeb5155c2..ceaf1426ef2 100644 --- a/container-core/abi-spec.json +++ b/container-core/abi-spec.json @@ -632,7 +632,8 @@ "public final com.yahoo.jdisc.handler.ContentChannel handleRequest(com.yahoo.jdisc.Request, com.yahoo.jdisc.handler.ResponseHandler)", "public java.time.Duration getTimeout()", "protected abstract void handleRequest(com.yahoo.jdisc.Request, com.yahoo.jdisc.handler.BufferedContentChannel, com.yahoo.jdisc.handler.ResponseHandler)", - "protected void writeErrorResponseOnOverload(com.yahoo.jdisc.Request, com.yahoo.jdisc.handler.ResponseHandler)" + "protected void writeErrorResponseOnOverload(com.yahoo.jdisc.Request, com.yahoo.jdisc.handler.ResponseHandler)", + "protected java.util.concurrent.Executor executor()" ], "fields": [ "protected final com.yahoo.jdisc.Metric metric" diff --git a/container-core/src/main/java/com/yahoo/container/jdisc/ThreadedRequestHandler.java b/container-core/src/main/java/com/yahoo/container/jdisc/ThreadedRequestHandler.java index 0e8865538ee..ab768dba0d2 100644 --- a/container-core/src/main/java/com/yahoo/container/jdisc/ThreadedRequestHandler.java +++ b/container-core/src/main/java/com/yahoo/container/jdisc/ThreadedRequestHandler.java @@ -169,6 +169,8 @@ public abstract class ThreadedRequestHandler extends AbstractRequestHandler { ResponseDispatch.newInstance(Response.Status.SERVICE_UNAVAILABLE).dispatch(responseHandler); } + protected Executor executor() { return executor; } + private class RequestTask implements ResponseHandler, Runnable { final Request request; |