refactor: 调整 Dynamic ThreadPool Starter 包级目录.

pull/161/head v0.2.0
chen.ma 3 years ago
parent c3acecd31d
commit 3660b0dfaa

@ -1,4 +1,4 @@
package io.dynamic.threadpool.starter.common; package io.dynamic.threadpool.starter.config;
import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum; import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum;
import io.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder; import io.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder;

@ -1,13 +1,13 @@
package io.dynamic.threadpool.starter.config; package io.dynamic.threadpool.starter.config;
import io.dynamic.threadpool.common.config.CommonConfiguration; import io.dynamic.threadpool.common.config.CommonConfiguration;
import io.dynamic.threadpool.starter.adapter.ThreadPoolConfigAdapter; import io.dynamic.threadpool.starter.core.ThreadPoolConfigAdapter;
import io.dynamic.threadpool.starter.controller.PoolRunStateController; import io.dynamic.threadpool.starter.controller.PoolRunStateController;
import io.dynamic.threadpool.starter.core.ConfigService; import io.dynamic.threadpool.starter.core.ConfigService;
import io.dynamic.threadpool.starter.core.ThreadPoolConfigService; import io.dynamic.threadpool.starter.core.ThreadPoolConfigService;
import io.dynamic.threadpool.starter.enable.DynamicThreadPoolMarkerConfiguration; import io.dynamic.threadpool.starter.enable.DynamicThreadPoolMarkerConfiguration;
import io.dynamic.threadpool.starter.listener.ThreadPoolRunListener; import io.dynamic.threadpool.starter.listener.ThreadPoolRunListener;
import io.dynamic.threadpool.starter.operation.ThreadPoolOperation; import io.dynamic.threadpool.starter.core.ThreadPoolOperation;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.autoconfigure.ImportAutoConfiguration; import org.springframework.boot.autoconfigure.ImportAutoConfiguration;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.starter.banner; package io.dynamic.threadpool.starter.config;
import org.springframework.boot.ansi.AnsiColor; import org.springframework.boot.ansi.AnsiColor;
import org.springframework.boot.ansi.AnsiOutput; import org.springframework.boot.ansi.AnsiOutput;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.starter.adapter; package io.dynamic.threadpool.starter.core;
import io.dynamic.threadpool.starter.core.ThreadPoolDynamicRefresh; import io.dynamic.threadpool.starter.core.ThreadPoolDynamicRefresh;

@ -1,8 +1,7 @@
package io.dynamic.threadpool.starter.adapter; package io.dynamic.threadpool.starter.core;
import io.dynamic.threadpool.common.config.ApplicationContextHolder; import io.dynamic.threadpool.common.config.ApplicationContextHolder;
import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum; import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum;
import io.dynamic.threadpool.starter.operation.ThreadPoolOperation;
import io.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder; import io.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder;
import io.dynamic.threadpool.starter.wrap.DynamicThreadPoolWrap; import io.dynamic.threadpool.starter.wrap.DynamicThreadPoolWrap;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

@ -1,7 +1,6 @@
package io.dynamic.threadpool.starter.operation; package io.dynamic.threadpool.starter.core;
import io.dynamic.threadpool.starter.config.DynamicThreadPoolProperties; import io.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import io.dynamic.threadpool.starter.core.ConfigService;
import io.dynamic.threadpool.starter.listener.Listener; import io.dynamic.threadpool.starter.listener.Listener;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.starter.operation; package io.dynamic.threadpool.starter.core;
/** /**
* ThreadPoolSubscribeCallback. * ThreadPoolSubscribeCallback.

@ -1,7 +1,7 @@
package io.dynamic.threadpool.starter.handler; package io.dynamic.threadpool.starter.handler;
import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum; import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum;
import io.dynamic.threadpool.starter.core.ResizableCapacityLinkedBlockIngQueue; import io.dynamic.threadpool.starter.toolkit.thread.ResizableCapacityLinkedBlockIngQueue;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.util.Objects; import java.util.Objects;

@ -5,8 +5,8 @@ import io.dynamic.threadpool.common.config.ApplicationContextHolder;
import io.dynamic.threadpool.common.constant.Constants; import io.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.model.PoolParameterInfo; import io.dynamic.threadpool.common.model.PoolParameterInfo;
import io.dynamic.threadpool.common.web.base.Result; import io.dynamic.threadpool.common.web.base.Result;
import io.dynamic.threadpool.starter.banner.DynamicThreadPoolBanner; import io.dynamic.threadpool.starter.config.DynamicThreadPoolBanner;
import io.dynamic.threadpool.starter.common.CommonThreadPool; import io.dynamic.threadpool.starter.config.CommonThreadPool;
import io.dynamic.threadpool.starter.config.DynamicThreadPoolProperties; import io.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import io.dynamic.threadpool.starter.core.GlobalThreadPoolManage; import io.dynamic.threadpool.starter.core.GlobalThreadPoolManage;
import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum; import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.starter.builder; package io.dynamic.threadpool.starter.toolkit.thread;
import java.io.Serializable; import java.io.Serializable;

@ -1,6 +1,5 @@
package io.dynamic.threadpool.starter.toolkit.thread; package io.dynamic.threadpool.starter.toolkit.thread;
import io.dynamic.threadpool.starter.core.ResizableCapacityLinkedBlockIngQueue;
import io.dynamic.threadpool.starter.spi.DynamicTpServiceLoader; import io.dynamic.threadpool.starter.spi.DynamicTpServiceLoader;
import io.dynamic.threadpool.starter.spi.queue.CustomBlockingQueue; import io.dynamic.threadpool.starter.spi.queue.CustomBlockingQueue;
@ -48,7 +47,7 @@ public enum QueueTypeEnum {
PRIORITY_BLOCKING_QUEUE(6), PRIORITY_BLOCKING_QUEUE(6),
/** /**
* {@link "io.dynamic.threadpool.starter.core.ResizableCapacityLinkedBlockIngQueue"} * {@link "io.dynamic.threadpool.starter.toolkit.thread.ResizableCapacityLinkedBlockIngQueue"}
*/ */
RESIZABLE_LINKED_BLOCKING_QUEUE(9); RESIZABLE_LINKED_BLOCKING_QUEUE(9);

@ -1,4 +1,4 @@
package io.dynamic.threadpool.starter.core; package io.dynamic.threadpool.starter.toolkit.thread;
import cn.hutool.core.util.ReflectUtil; import cn.hutool.core.util.ReflectUtil;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;

@ -1,7 +1,5 @@
package io.dynamic.threadpool.starter.toolkit.thread; package io.dynamic.threadpool.starter.toolkit.thread;
import io.dynamic.threadpool.starter.builder.Builder;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;

@ -2,7 +2,6 @@ package io.dynamic.threadpool.starter.toolkit.thread;
import io.dynamic.threadpool.common.toolkit.Assert; import io.dynamic.threadpool.common.toolkit.Assert;
import io.dynamic.threadpool.starter.builder.Builder;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.concurrent.*; import java.util.concurrent.*;

@ -1,6 +1,6 @@
package io.dynamic.threadpool.starter.wrap; package io.dynamic.threadpool.starter.wrap;
import io.dynamic.threadpool.starter.common.CommonThreadPool; import io.dynamic.threadpool.starter.config.CommonThreadPool;
import lombok.Data; import lombok.Data;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;

@ -1,6 +1,6 @@
package io.dynamic.threadpool.starter.test; package io.dynamic.threadpool.starter.test;
import io.dynamic.threadpool.starter.core.ResizableCapacityLinkedBlockIngQueue; import io.dynamic.threadpool.starter.toolkit.thread.ResizableCapacityLinkedBlockIngQueue;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.LinkedBlockingQueue;

Loading…
Cancel
Save