修复 ThreadLocal 内存泄漏问题.

2 years ago · dae61975e9
parent 2dff52142b
commit dae61975e9
1 changed files with 4 additions and 0 deletions
--- a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/DynamicThreadPoolExecutor.java
+++ b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/DynamicThreadPoolExecutor.java
@ -73,6 +73,10 @@ public class DynamicThreadPoolExecutor extends AbstractDynamicExecutorSupport {

    @Override
    protected void beforeExecute(Thread t, Runnable r) {
+        if (executeTimeOut == null || executeTimeOut <= 0) {
+            return;
+        }
+
        this.startTime.set(System.currentTimeMillis());
    }