summaryrefslogtreecommitdiffstats
path: root/container-core/src/main
diff options
context:
space:
mode:
authorBjørn Christian Seime <bjorncs@verizonmedia.com>2020-09-17 15:48:31 +0200
committerBjørn Christian Seime <bjorncs@verizonmedia.com>2020-09-22 14:39:16 +0200
commita4621d00adcc2fd6ece64b0ecacff05d3d20e67b (patch)
tree4efd9d02b940736d0ad726da61733d4303a490d5 /container-core/src/main
parent8cae83209c036e5d3bac4ef5aca05a78666c0111 (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.java5
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());