Use janitor thread pool instead of ad-hoc thread

1 files changed, 4 insertions, 2 deletions

diff --git a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/ServletResponseController.java b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/ServletResponseController.java
index ef24baa8f01..dbefa4a597e 100644
--- a/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/ServletResponseController.java
+++ b/jdisc_http_service/src/main/java/com/yahoo/jdisc/http/server/jetty/ServletResponseController.java
@@ -19,7 +19,6 @@ import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.Executor;
-import java.util.concurrent.Executors;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -40,6 +39,7 @@ public class ServletResponseController {
     //servletResponse must not be modified after the response has been committed.
     private final HttpServletResponse servletResponse;
     private final boolean developerMode;
+    private final Executor executor;
 
     //all calls to the servletOutputStreamWriter must hold the monitor first to ensure visibility of servletResponse changes.
     private final ServletOutputStreamWriter servletOutputStreamWriter;
@@ -48,6 +48,7 @@ public class ServletResponseController {
     private boolean responseCommitted = false;
 
 
+
     public ServletResponseController(
             HttpServletResponse servletResponse,
             Executor executor,
@@ -56,6 +57,7 @@ public class ServletResponseController {
 
         this.servletResponse = servletResponse;
         this.developerMode = developerMode;
+        this.executor = executor;
         this.servletOutputStreamWriter =
                 new ServletOutputStreamWriter(servletResponse.getOutputStream(), executor, metricReporter);
     }
@@ -117,7 +119,7 @@ public class ServletResponseController {
         try {
 
             // HttpServletResponse.sendError() is blocking and must not be executed in Jetty/RequestHandler thread.
-            Executors.newSingleThreadExecutor().execute(() -> {
+            executor.execute(() -> {
                 try {
                     // TODO We should control the response content this method generates
                     // a response body based on Jetty's own response templates ("Powered by Jetty").