diff options
author | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-09-17 15:48:31 +0200 |
---|---|---|
committer | Bjørn Christian Seime <bjorncs@verizonmedia.com> | 2020-09-22 14:39:16 +0200 |
commit | a4621d00adcc2fd6ece64b0ecacff05d3d20e67b (patch) | |
tree | 4efd9d02b940736d0ad726da61733d4303a490d5 /container-core/src/main | |
parent | 8cae83209c036e5d3bac4ef5aca05a78666c0111 (diff) |
Set name of metric reporter thread
Diffstat (limited to 'container-core/src/main')
-rw-r--r-- | container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java b/container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java index 9a73c98597a..3b2b5697e5c 100644 --- a/container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java +++ b/container-core/src/main/java/com/yahoo/container/handler/threadpool/ExecutorServiceWrapper.java @@ -30,7 +30,7 @@ class ExecutorServiceWrapper extends ForwardingExecutorService { ExecutorServiceWrapper( WorkerCompletionTimingThreadPoolExecutor wrapped, ThreadPoolMetric metric, ProcessTerminator processTerminator, - long maxThreadExecutionTimeMillis) { + long maxThreadExecutionTimeMillis, String name) { this.wrapped = wrapped; this.metric = metric; this.processTerminator = processTerminator; @@ -39,13 +39,14 @@ class ExecutorServiceWrapper extends ForwardingExecutorService { metric.reportThreadPoolSize(wrapped.getPoolSize()); metric.reportActiveThreads(wrapped.getActiveCount()); metricReporter = new Thread(this::reportMetrics); + metricReporter.setName(name + "-threadpool-metric-reporter"); metricReporter.setDaemon(true); metricReporter.start(); } int queuedTasks() { return wrapped.getQueue().size(); } - private final void reportMetrics() { + private void reportMetrics() { try { while (!closed.get()) { metric.reportThreadPoolSize(wrapped.getPoolSize()); |