optimize

Author: lvyahui8

spring-boot-data-aggregator-autoconfigure/src/main/java/io/github/lvyahui8/spring/autoconfigure/BeanAggregateAutoConfiguration.java

@@ -142,7 +142,7 @@ public DataBeanAggregateQueryService dataBeanAggregateQueryService (
     /**
      * 允许用户自定义线程池
      *
-     * @return
+     * @return 线程池服务
      */
     @Bean(name = "aggregateExecutorService")
     @ConditionalOnMissingBean(name = "aggregateExecutorService",value=ExecutorService.class)
@@ -158,7 +158,7 @@ public ExecutorService aggregateExecutorService() {
     /**
      * 允许用户自定义provider存储
      *
-     * @return
+     * @return  provider数据仓库
      */
     @Bean(name = "dataProviderRepository")
     @ConditionalOnMissingBean(DataProviderRepository.class)

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/concurrent/AbstractRunnableWrapper.java

@@ -16,7 +16,7 @@ public abstract class AbstractAsyncQueryTask<T> implements Callable<T> {
      */
     private AsyncQueryTaskWrapper asyncQueryTaskWrapper;
 
-    public AbstractAsyncQueryTask(Thread taskFromThread, AsyncQueryTaskWrapper asyncQueryTaskWrapper) {
+    protected AbstractAsyncQueryTask(Thread taskFromThread, AsyncQueryTaskWrapper asyncQueryTaskWrapper) {
         this.taskFromThread = taskFromThread;
         this.asyncQueryTaskWrapper = asyncQueryTaskWrapper;
     }

spring-boot-data-aggregator-core/src/main/java/io/github/lvyahui8/spring/aggregate/service/AbstractAsyncQueryTask.java

@@ -75,7 +75,7 @@ public <T> T get(DataProvideDefinition provider, Map<String, Object> invokeParam
     private  <T> T innerGet(DataProvideDefinition provider, Map<String, Object> invokeParams, Class<T> resultType,
                      AggregationContext context, DataConsumeDefinition causedConsumer)
             throws InterruptedException, InvocationTargetException, IllegalAccessException{
-        Map<String,Object> dependObjectMap = null;
+        Map<String,Object> dependObjectMap;
         try {
             interceptorChain.applyQueryBefore(context,provider);
             if(provider.getDepends() != null && ! provider.getDepends().isEmpty()) {
@@ -144,7 +144,7 @@ private Map<String, Object> getDependObjectMap(Map<String, Object> invokeParams,
         Map<String,DataConsumeDefinition> consumeDefinitionMap = new HashMap<>(consumeDefinitions.size());
         for (DataConsumeDefinition depend : consumeDefinitions) {
             consumeDefinitionMap.put(depend.getId(),depend);
-            AsyncQueryTaskWrapper taskWrapper = null;
+            AsyncQueryTaskWrapper taskWrapper;
             try {
                 taskWrapper = taskWrapperClazz.newInstance();
             } catch (InstantiationException e) {