diff --git a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/ThreadPoolTaskExecutorAdapter.java b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/ThreadPoolTaskExecutorAdapter.java index ebf655d5..2739bcef 100644 --- a/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/ThreadPoolTaskExecutorAdapter.java +++ b/hippo4j-core/src/main/java/cn/hippo4j/core/executor/support/adpter/ThreadPoolTaskExecutorAdapter.java @@ -62,10 +62,10 @@ public class ThreadPoolTaskExecutorAdapter implements DynamicThreadPoolAdapter { if (unwrap instanceof DynamicThreadPoolExecutor) { return (DynamicThreadPoolExecutor) unwrap; } - boolean waitForTasksToCompleteOnShutdown = (boolean)ReflectUtil.getFieldValue(executor, WAIT_FOR_TASKS_TO_COMPLETE_ON_SHUTDOWN); - long awaitTerminationMillis = (long)ReflectUtil.getFieldValue(executor, AWAIT_TERMINATION_MILLIS); - String beanName = (String)ReflectUtil.getFieldValue(executor, BEAN_NAME); - int queueCapacity = (int)ReflectUtil.getFieldValue(executor, QUEUE_CAPACITY); + boolean waitForTasksToCompleteOnShutdown = (boolean) ReflectUtil.getFieldValue(executor, WAIT_FOR_TASKS_TO_COMPLETE_ON_SHUTDOWN); + long awaitTerminationMillis = (long) ReflectUtil.getFieldValue(executor, AWAIT_TERMINATION_MILLIS); + String beanName = (String) ReflectUtil.getFieldValue(executor, BEAN_NAME); + int queueCapacity = (int) ReflectUtil.getFieldValue(executor, QUEUE_CAPACITY); ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) unwrap; ThreadPoolTaskExecutor threadPoolTaskExecutor = (ThreadPoolTaskExecutor) executor; @@ -81,11 +81,10 @@ public class ThreadPoolTaskExecutorAdapter implements DynamicThreadPoolAdapter { .waitForTasksToCompleteOnShutdown(waitForTasksToCompleteOnShutdown) .awaitTerminationMillis(awaitTerminationMillis) .threadFactory(threadPoolExecutor.getThreadFactory()) - //threadPoolId default beanName + // threadPoolId default beanName .threadPoolId(beanName) - .rejected(threadPoolExecutor.getRejectedExecutionHandler()) - ; - //use new Queue + .rejected(threadPoolExecutor.getRejectedExecutionHandler()); + // use new Queue threadPoolBuilder.capacity(queueCapacity); // .workQueue(threadPoolExecutor.getQueue())