diff options
author | Jon Bratseth <bratseth@oath.com> | 2018-06-15 09:48:09 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@oath.com> | 2018-06-15 09:48:09 +0200 |
commit | 44bf40a48f361c2c21583c491741e29690610f6f (patch) | |
tree | c231fcb327f3c8ad18c565b692decc97e33c73f3 /container-core | |
parent | 60773276ccee8a0e181570a59873c3ace4b8dff5 (diff) |
Change field name
Diffstat (limited to 'container-core')
-rw-r--r-- | container-core/src/main/java/com/yahoo/container/handler/ThreadPoolProvider.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/container-core/src/main/java/com/yahoo/container/handler/ThreadPoolProvider.java b/container-core/src/main/java/com/yahoo/container/handler/ThreadPoolProvider.java index 4bc1063ccbd..4cc3b48fd1a 100644 --- a/container-core/src/main/java/com/yahoo/container/handler/ThreadPoolProvider.java +++ b/container-core/src/main/java/com/yahoo/container/handler/ThreadPoolProvider.java @@ -139,7 +139,7 @@ public class ThreadPoolProvider extends AbstractComponent implements Provider<Ex super.execute(command); } catch (RejectedExecutionException e) { metric.add(MetricNames.REJECTED_REQUEST, 1, null); - long timeSinceLastReturnedThreadMillis = System.currentTimeMillis() - wrapped.lastThreadReturnTimeMillis; + long timeSinceLastReturnedThreadMillis = System.currentTimeMillis() - wrapped.lastThreadAssignmentTimeMillis; if (timeSinceLastReturnedThreadMillis > maxThreadExecutionTimeMillis) processTerminator.logAndDie("No worker threads have been available for " + timeSinceLastReturnedThreadMillis + " ms. Shutting down.", true); @@ -161,7 +161,7 @@ public class ThreadPoolProvider extends AbstractComponent implements Provider<Ex /** A thread pool executor which maintains the last time a worker completed */ private final static class WorkerCompletionTimingThreadPoolExecutor extends ThreadPoolExecutor { - volatile long lastThreadReturnTimeMillis = System.currentTimeMillis(); + volatile long lastThreadAssignmentTimeMillis = System.currentTimeMillis(); private final AtomicLong startedCount = new AtomicLong(0); private final AtomicLong completedCount = new AtomicLong(0); @@ -177,7 +177,7 @@ public class ThreadPoolProvider extends AbstractComponent implements Provider<Ex @Override protected void beforeExecute(Thread t, Runnable r) { super.beforeExecute(t, r); - lastThreadReturnTimeMillis = System.currentTimeMillis(); + lastThreadAssignmentTimeMillis = System.currentTimeMillis(); startedCount.incrementAndGet(); } |