optimize: 全局修改 Maven GroupId.

pull/161/head
龙台 3 years ago
parent d1df7ad410
commit b69aabe55d

@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>io.dynamic-threadpool</groupId> <groupId>com.github.dynamic-threadpool</groupId>
<artifactId>parent</artifactId> <artifactId>parent</artifactId>
<version>1.0.0-SNAPSHOT</version> <version>1.0.0-SNAPSHOT</version>
</parent> </parent>

@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>io.dynamic-threadpool</groupId> <groupId>com.github.dynamic-threadpool</groupId>
<artifactId>parent</artifactId> <artifactId>parent</artifactId>
<version>1.0.0-SNAPSHOT</version> <version>1.0.0-SNAPSHOT</version>
</parent> </parent>

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.config; package com.github.dynamic.threadpool.common.config;
import org.springframework.beans.BeansException; import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContext;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.constant; package com.github.dynamic.threadpool.common.constant;
/** /**
* Constants * Constants

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.executor; package com.github.dynamic.threadpool.common.executor;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.executor; package com.github.dynamic.threadpool.common.executor;
import java.util.HashMap; import java.util.HashMap;
import java.util.HashSet; import java.util.HashSet;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.model; package com.github.dynamic.threadpool.common.model;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.model; package com.github.dynamic.threadpool.common.model;
/** /**
* Pool Parameter. * Pool Parameter.

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.model; package com.github.dynamic.threadpool.common.model;
import lombok.Data; import lombok.Data;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.model; package com.github.dynamic.threadpool.common.model;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.toolkit; package com.github.dynamic.threadpool.common.toolkit;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;

@ -1,9 +1,9 @@
package io.dynamic.threadpool.common.toolkit; package com.github.dynamic.threadpool.common.toolkit;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.model.PoolParameter; import com.github.dynamic.threadpool.common.model.PoolParameter;
import io.dynamic.threadpool.common.model.PoolParameterInfo; import com.github.dynamic.threadpool.common.model.PoolParameterInfo;
/** /**
* Content Util. * Content Util.

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.toolkit; package com.github.dynamic.threadpool.common.toolkit;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;

@ -1,7 +1,7 @@
package io.dynamic.threadpool.common.toolkit; package com.github.dynamic.threadpool.common.toolkit;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.model.PoolParameter; import com.github.dynamic.threadpool.common.model.PoolParameter;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import java.io.IOException; import java.io.IOException;
@ -10,7 +10,7 @@ import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException; import java.security.NoSuchAlgorithmException;
import java.util.List; import java.util.List;
import static io.dynamic.threadpool.common.constant.Constants.WORD_SEPARATOR; import static com.github.dynamic.threadpool.common.constant.Constants.WORD_SEPARATOR;
/** /**
* MD5 Util. * MD5 Util.

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.web.base; package com.github.dynamic.threadpool.common.web.base;
import lombok.Data; import lombok.Data;
import lombok.experimental.Accessors; import lombok.experimental.Accessors;

@ -1,7 +1,7 @@
package io.dynamic.threadpool.common.web.base; package com.github.dynamic.threadpool.common.web.base;
import io.dynamic.threadpool.common.web.exception.ErrorCode; import com.github.dynamic.threadpool.common.web.exception.ErrorCode;
import io.dynamic.threadpool.common.web.exception.ServiceException; import com.github.dynamic.threadpool.common.web.exception.ServiceException;
/** /**
* Result * Result

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.web.exception; package com.github.dynamic.threadpool.common.web.exception;
/** /**
* *

@ -1,4 +1,4 @@
package io.dynamic.threadpool.common.web.exception; package com.github.dynamic.threadpool.common.web.exception;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;

@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>io.dynamic-threadpool</groupId> <groupId>com.github.dynamic-threadpool</groupId>
<artifactId>parent</artifactId> <artifactId>parent</artifactId>
<version>1.0.0-SNAPSHOT</version> <version>1.0.0-SNAPSHOT</version>
</parent> </parent>
@ -43,7 +43,7 @@
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.dynamic-threadpool</groupId> <groupId>com.github.dynamic-threadpool</groupId>
<artifactId>dynamic-threadpool-common</artifactId> <artifactId>dynamic-threadpool-common</artifactId>
</dependency> </dependency>

@ -1,6 +1,6 @@
package io.dynamic.threadpool.config.config; package com.github.dynamic.threadpool.config.config;
import io.dynamic.threadpool.common.config.ApplicationContextHolder; import com.github.dynamic.threadpool.common.config.ApplicationContextHolder;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;

@ -1,7 +1,7 @@
package io.dynamic.threadpool.config.config; package com.github.dynamic.threadpool.config.config;
import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler; import com.baomidou.mybatisplus.core.handlers.MetaObjectHandler;
import io.dynamic.threadpool.config.enums.DelEnum; import com.github.dynamic.threadpool.config.enums.DelEnum;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.reflection.MetaObject; import org.apache.ibatis.reflection.MetaObject;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.config; package com.github.dynamic.threadpool.config.config;
import com.baomidou.mybatisplus.annotation.DbType; import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor; import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;

@ -1,13 +1,13 @@
package io.dynamic.threadpool.config.controller; package com.github.dynamic.threadpool.config.controller;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.config.service.biz.ConfigService;
import io.dynamic.threadpool.common.web.base.Result; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.web.base.Results; import com.github.dynamic.threadpool.common.web.base.Result;
import io.dynamic.threadpool.config.model.ConfigAllInfo; import com.github.dynamic.threadpool.common.web.base.Results;
import io.dynamic.threadpool.config.model.ConfigInfoBase; import com.github.dynamic.threadpool.config.model.ConfigAllInfo;
import io.dynamic.threadpool.config.service.biz.ConfigService; import com.github.dynamic.threadpool.config.model.ConfigInfoBase;
import io.dynamic.threadpool.config.service.ConfigServletInner; import com.github.dynamic.threadpool.config.service.ConfigServletInner;
import io.dynamic.threadpool.config.toolkit.Md5ConfigUtil; import com.github.dynamic.threadpool.config.toolkit.Md5ConfigUtil;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.enums; package com.github.dynamic.threadpool.config.enums;
/** /**
* *

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.event; package com.github.dynamic.threadpool.config.event;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.event; package com.github.dynamic.threadpool.config.event;
import java.io.Serializable; import java.io.Serializable;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.event; package com.github.dynamic.threadpool.config.event;
/** /**
* Local Data Change Event. * Local Data Change Event.

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.event; package com.github.dynamic.threadpool.config.event;
/** /**
* Slow Event. * Slow Event.

@ -1,7 +1,7 @@
package io.dynamic.threadpool.config.mapper; package com.github.dynamic.threadpool.config.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import io.dynamic.threadpool.config.model.ConfigAllInfo; import com.github.dynamic.threadpool.config.model.ConfigAllInfo;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
/** /**

@ -1,7 +1,7 @@
package io.dynamic.threadpool.config.mapper; package com.github.dynamic.threadpool.config.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import io.dynamic.threadpool.config.model.ItemInfo; import com.github.dynamic.threadpool.config.model.ItemInfo;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
/** /**

@ -1,7 +1,7 @@
package io.dynamic.threadpool.config.mapper; package com.github.dynamic.threadpool.config.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import io.dynamic.threadpool.config.model.TenantInfo; import com.github.dynamic.threadpool.config.model.TenantInfo;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
/** /**

@ -1,8 +1,8 @@
package io.dynamic.threadpool.config.model; package com.github.dynamic.threadpool.config.model;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.config.toolkit.SimpleReadWriteLock;
import io.dynamic.threadpool.config.toolkit.SimpleReadWriteLock; import com.github.dynamic.threadpool.config.toolkit.SingletonRepository;
import io.dynamic.threadpool.config.toolkit.SingletonRepository; import com.github.dynamic.threadpool.common.constant.Constants;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;

@ -1,11 +1,11 @@
package io.dynamic.threadpool.config.model; package com.github.dynamic.threadpool.config.model;
import com.alibaba.fastjson.annotation.JSONField; import com.alibaba.fastjson.annotation.JSONField;
import com.baomidou.mybatisplus.annotation.FieldFill; import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableLogic; import com.baomidou.mybatisplus.annotation.TableLogic;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import io.dynamic.threadpool.common.model.PoolParameter; import com.github.dynamic.threadpool.common.model.PoolParameter;
import lombok.Data; import lombok.Data;
import java.util.Date; import java.util.Date;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model; package com.github.dynamic.threadpool.config.model;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model; package com.github.dynamic.threadpool.config.model;
import com.alibaba.fastjson.annotation.JSONField; import com.alibaba.fastjson.annotation.JSONField;
import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.IdType;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model; package com.github.dynamic.threadpool.config.model;
import com.baomidou.mybatisplus.annotation.*; import com.baomidou.mybatisplus.annotation.*;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model; package com.github.dynamic.threadpool.config.model;
import com.baomidou.mybatisplus.annotation.*; import com.baomidou.mybatisplus.annotation.*;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.item; package com.github.dynamic.threadpool.config.model.biz.item;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.item; package com.github.dynamic.threadpool.config.model.biz.item;
import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.item; package com.github.dynamic.threadpool.config.model.biz.item;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.item; package com.github.dynamic.threadpool.config.model.biz.item;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.tenant; package com.github.dynamic.threadpool.config.model.biz.tenant;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.tenant; package com.github.dynamic.threadpool.config.model.biz.tenant;
import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.tenant; package com.github.dynamic.threadpool.config.model.biz.tenant;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.tenant; package com.github.dynamic.threadpool.config.model.biz.tenant;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.threadpool; package com.github.dynamic.threadpool.config.model.biz.threadpool;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.threadpool; package com.github.dynamic.threadpool.config.model.biz.threadpool;
import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonFormat;
import lombok.Data; import lombok.Data;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.model.biz.threadpool; package com.github.dynamic.threadpool.config.model.biz.threadpool;
import lombok.Data; import lombok.Data;

@ -1,8 +1,8 @@
package io.dynamic.threadpool.config.notify; package com.github.dynamic.threadpool.config.notify;
import cn.hutool.core.collection.ConcurrentHashSet; import cn.hutool.core.collection.ConcurrentHashSet;
import io.dynamic.threadpool.config.event.Event; import com.github.dynamic.threadpool.config.notify.listener.Subscriber;
import io.dynamic.threadpool.config.notify.listener.Subscriber; import com.github.dynamic.threadpool.config.event.Event;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;

@ -1,9 +1,9 @@
package io.dynamic.threadpool.config.notify; package com.github.dynamic.threadpool.config.notify;
import cn.hutool.core.collection.ConcurrentHashSet; import cn.hutool.core.collection.ConcurrentHashSet;
import io.dynamic.threadpool.config.event.Event; import com.github.dynamic.threadpool.config.notify.listener.Subscriber;
import io.dynamic.threadpool.config.event.SlowEvent; import com.github.dynamic.threadpool.config.event.Event;
import io.dynamic.threadpool.config.notify.listener.Subscriber; import com.github.dynamic.threadpool.config.event.SlowEvent;
import java.util.Map; import java.util.Map;
import java.util.Set; import java.util.Set;

@ -1,7 +1,7 @@
package io.dynamic.threadpool.config.notify; package com.github.dynamic.threadpool.config.notify;
import io.dynamic.threadpool.config.event.Event; import com.github.dynamic.threadpool.config.notify.listener.Subscriber;
import io.dynamic.threadpool.config.notify.listener.Subscriber; import com.github.dynamic.threadpool.config.event.Event;
/** /**
* Event publisher. * Event publisher.

@ -1,11 +1,11 @@
package io.dynamic.threadpool.config.notify; package com.github.dynamic.threadpool.config.notify;
import io.dynamic.threadpool.config.event.Event; import com.github.dynamic.threadpool.config.notify.listener.SmartSubscriber;
import io.dynamic.threadpool.config.event.SlowEvent; import com.github.dynamic.threadpool.config.notify.listener.Subscriber;
import io.dynamic.threadpool.config.notify.listener.SmartSubscriber; import com.github.dynamic.threadpool.config.toolkit.ClassUtil;
import io.dynamic.threadpool.config.notify.listener.Subscriber; import com.github.dynamic.threadpool.config.toolkit.MapUtil;
import io.dynamic.threadpool.config.toolkit.ClassUtil; import com.github.dynamic.threadpool.config.event.Event;
import io.dynamic.threadpool.config.toolkit.MapUtil; import com.github.dynamic.threadpool.config.event.SlowEvent;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.util.Map; import java.util.Map;

@ -1,6 +1,6 @@
package io.dynamic.threadpool.config.notify.listener; package com.github.dynamic.threadpool.config.notify.listener;
import io.dynamic.threadpool.config.event.Event; import com.github.dynamic.threadpool.config.event.Event;
import java.util.List; import java.util.List;

@ -1,6 +1,6 @@
package io.dynamic.threadpool.config.notify.listener; package com.github.dynamic.threadpool.config.notify.listener;
import io.dynamic.threadpool.config.event.Event; import com.github.dynamic.threadpool.config.event.Event;
import java.util.concurrent.Executor; import java.util.concurrent.Executor;

@ -1,13 +1,13 @@
package io.dynamic.threadpool.config.service; package com.github.dynamic.threadpool.config.service;
import io.dynamic.threadpool.common.config.ApplicationContextHolder; import com.github.dynamic.threadpool.config.service.biz.ConfigService;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.config.ApplicationContextHolder;
import io.dynamic.threadpool.common.toolkit.Md5Util; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.config.event.LocalDataChangeEvent; import com.github.dynamic.threadpool.common.toolkit.Md5Util;
import io.dynamic.threadpool.config.model.CacheItem; import com.github.dynamic.threadpool.config.event.LocalDataChangeEvent;
import io.dynamic.threadpool.config.model.ConfigAllInfo; import com.github.dynamic.threadpool.config.model.CacheItem;
import io.dynamic.threadpool.config.notify.NotifyCenter; import com.github.dynamic.threadpool.config.model.ConfigAllInfo;
import io.dynamic.threadpool.config.service.biz.ConfigService; import com.github.dynamic.threadpool.config.notify.NotifyCenter;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import java.util.Objects; import java.util.Objects;

@ -1,7 +1,7 @@
package io.dynamic.threadpool.config.service; package com.github.dynamic.threadpool.config.service;
import io.dynamic.threadpool.config.event.LocalDataChangeEvent; import com.github.dynamic.threadpool.config.event.LocalDataChangeEvent;
import io.dynamic.threadpool.config.notify.NotifyCenter; import com.github.dynamic.threadpool.config.notify.NotifyCenter;
/** /**
* Config Change Publisher. * Config Change Publisher.

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.service; package com.github.dynamic.threadpool.config.service;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

@ -1,15 +1,15 @@
package io.dynamic.threadpool.config.service; package com.github.dynamic.threadpool.config.service;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import io.dynamic.threadpool.common.toolkit.Md5Util; import com.github.dynamic.threadpool.config.notify.listener.Subscriber;
import io.dynamic.threadpool.common.web.base.Results; import com.github.dynamic.threadpool.config.toolkit.ConfigExecutor;
import io.dynamic.threadpool.config.event.Event; import com.github.dynamic.threadpool.config.toolkit.Md5ConfigUtil;
import io.dynamic.threadpool.config.event.LocalDataChangeEvent; import com.github.dynamic.threadpool.config.toolkit.RequestUtil;
import io.dynamic.threadpool.config.notify.NotifyCenter; import com.github.dynamic.threadpool.common.toolkit.Md5Util;
import io.dynamic.threadpool.config.notify.listener.Subscriber; import com.github.dynamic.threadpool.common.web.base.Results;
import io.dynamic.threadpool.config.toolkit.ConfigExecutor; import com.github.dynamic.threadpool.config.event.Event;
import io.dynamic.threadpool.config.toolkit.Md5ConfigUtil; import com.github.dynamic.threadpool.config.event.LocalDataChangeEvent;
import io.dynamic.threadpool.config.toolkit.RequestUtil; import com.github.dynamic.threadpool.config.notify.NotifyCenter;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.service; package com.github.dynamic.threadpool.config.service;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

@ -1,6 +1,6 @@
package io.dynamic.threadpool.config.service.biz; package com.github.dynamic.threadpool.config.service.biz;
import io.dynamic.threadpool.config.model.ConfigAllInfo; import com.github.dynamic.threadpool.config.model.ConfigAllInfo;
/** /**
* *

@ -1,16 +1,16 @@
package io.dynamic.threadpool.config.service.biz; package com.github.dynamic.threadpool.config.service.biz;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.toolkit.SqlHelper; import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
import io.dynamic.threadpool.common.toolkit.ContentUtil; import com.github.dynamic.threadpool.common.toolkit.ContentUtil;
import io.dynamic.threadpool.common.toolkit.Md5Util; import com.github.dynamic.threadpool.common.toolkit.Md5Util;
import io.dynamic.threadpool.config.event.LocalDataChangeEvent; import com.github.dynamic.threadpool.config.event.LocalDataChangeEvent;
import io.dynamic.threadpool.config.mapper.ConfigInfoMapper; import com.github.dynamic.threadpool.config.mapper.ConfigInfoMapper;
import io.dynamic.threadpool.config.model.ConfigAllInfo; import com.github.dynamic.threadpool.config.model.ConfigAllInfo;
import io.dynamic.threadpool.config.service.ConfigChangePublisher; import com.github.dynamic.threadpool.config.service.ConfigChangePublisher;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

@ -1,10 +1,10 @@
package io.dynamic.threadpool.config.service.biz; package com.github.dynamic.threadpool.config.service.biz;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import io.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemRespDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemRespDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO;
import java.util.List; import java.util.List;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.service.biz; package com.github.dynamic.threadpool.config.service.biz;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
@ -6,15 +6,15 @@ import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.toolkit.SqlHelper; import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
import io.dynamic.threadpool.config.enums.DelEnum; import com.github.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO;
import io.dynamic.threadpool.config.mapper.ItemInfoMapper; import com.github.dynamic.threadpool.config.model.biz.item.ItemRespDTO;
import io.dynamic.threadpool.config.model.ItemInfo; import com.github.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemRespDTO; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO; import com.github.dynamic.threadpool.config.enums.DelEnum;
import io.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO; import com.github.dynamic.threadpool.config.mapper.ItemInfoMapper;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO; import com.github.dynamic.threadpool.config.model.ItemInfo;
import io.dynamic.threadpool.config.toolkit.BeanUtil; import com.github.dynamic.threadpool.config.toolkit.BeanUtil;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

@ -1,10 +1,10 @@
package io.dynamic.threadpool.config.service.biz; package com.github.dynamic.threadpool.config.service.biz;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import io.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO;
import io.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO;
import io.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO;
import io.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO;
/** /**
* *

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.service.biz; package com.github.dynamic.threadpool.config.service.biz;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
@ -6,16 +6,16 @@ import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.toolkit.SqlHelper; import com.baomidou.mybatisplus.extension.toolkit.SqlHelper;
import io.dynamic.threadpool.config.enums.DelEnum; import com.github.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO;
import io.dynamic.threadpool.config.mapper.TenantInfoMapper; import com.github.dynamic.threadpool.config.model.biz.item.ItemRespDTO;
import io.dynamic.threadpool.config.model.TenantInfo; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemRespDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO;
import io.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO;
import io.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO; import com.github.dynamic.threadpool.config.enums.DelEnum;
import io.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO; import com.github.dynamic.threadpool.config.mapper.TenantInfoMapper;
import io.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO; import com.github.dynamic.threadpool.config.model.TenantInfo;
import io.dynamic.threadpool.config.toolkit.BeanUtil; import com.github.dynamic.threadpool.config.toolkit.BeanUtil;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

@ -1,9 +1,9 @@
package io.dynamic.threadpool.config.service.biz; package com.github.dynamic.threadpool.config.service.biz;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
import java.util.List; import java.util.List;

@ -1,15 +1,15 @@
package io.dynamic.threadpool.config.service.biz; package com.github.dynamic.threadpool.config.service.biz;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import io.dynamic.threadpool.config.mapper.ConfigInfoMapper; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO;
import io.dynamic.threadpool.config.model.ConfigAllInfo; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO; import com.github.dynamic.threadpool.config.mapper.ConfigInfoMapper;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO; import com.github.dynamic.threadpool.config.model.ConfigAllInfo;
import io.dynamic.threadpool.config.toolkit.BeanUtil; import com.github.dynamic.threadpool.config.toolkit.BeanUtil;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.toolkit; package com.github.dynamic.threadpool.config.toolkit;
import com.github.dozermapper.core.DozerBeanMapperBuilder; import com.github.dozermapper.core.DozerBeanMapperBuilder;
import com.github.dozermapper.core.Mapper; import com.github.dozermapper.core.Mapper;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.toolkit; package com.github.dynamic.threadpool.config.toolkit;
import java.util.Objects; import java.util.Objects;

@ -1,7 +1,7 @@
package io.dynamic.threadpool.config.toolkit; package com.github.dynamic.threadpool.config.toolkit;
import cn.hutool.core.thread.ThreadFactoryBuilder; import cn.hutool.core.thread.ThreadFactoryBuilder;
import io.dynamic.threadpool.common.executor.ExecutorFactory; import com.github.dynamic.threadpool.common.executor.ExecutorFactory;
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture; import java.util.concurrent.ScheduledFuture;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.toolkit; package com.github.dynamic.threadpool.config.toolkit;
import java.util.Map; import java.util.Map;
import java.util.Objects; import java.util.Objects;

@ -1,9 +1,9 @@
package io.dynamic.threadpool.config.toolkit; package com.github.dynamic.threadpool.config.toolkit;
import io.dynamic.threadpool.common.toolkit.GroupKey; import com.github.dynamic.threadpool.common.toolkit.GroupKey;
import io.dynamic.threadpool.common.toolkit.Md5Util; import com.github.dynamic.threadpool.common.toolkit.Md5Util;
import io.dynamic.threadpool.config.model.ConfigAllInfo; import com.github.dynamic.threadpool.config.model.ConfigAllInfo;
import io.dynamic.threadpool.config.service.ConfigCacheService; import com.github.dynamic.threadpool.config.service.ConfigCacheService;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
@ -14,8 +14,8 @@ import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import static io.dynamic.threadpool.common.constant.Constants.LINE_SEPARATOR; import static com.github.dynamic.threadpool.common.constant.Constants.LINE_SEPARATOR;
import static io.dynamic.threadpool.common.constant.Constants.WORD_SEPARATOR; import static com.github.dynamic.threadpool.common.constant.Constants.WORD_SEPARATOR;
/** /**

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.toolkit; package com.github.dynamic.threadpool.config.toolkit;
import org.springframework.util.StringUtils; import org.springframework.util.StringUtils;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.toolkit; package com.github.dynamic.threadpool.config.toolkit;
/** /**
* . * .

@ -1,4 +1,4 @@
package io.dynamic.threadpool.config.toolkit; package com.github.dynamic.threadpool.config.toolkit;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;

@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>io.dynamic-threadpool</groupId> <groupId>com.github.dynamic-threadpool</groupId>
<artifactId>parent</artifactId> <artifactId>parent</artifactId>
<version>1.0.0-SNAPSHOT</version> <version>1.0.0-SNAPSHOT</version>
</parent> </parent>
@ -17,7 +17,7 @@
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>io.dynamic-threadpool</groupId> <groupId>com.github.dynamic-threadpool</groupId>
<artifactId>dynamic-threadpool-config</artifactId> <artifactId>dynamic-threadpool-config</artifactId>
</dependency> </dependency>
</dependencies> </dependencies>

@ -1,14 +1,14 @@
package io.dynamic.threadpool.console.controller; package com.github.dynamic.threadpool.console.controller;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.web.base.Result; import com.github.dynamic.threadpool.common.web.base.Result;
import io.dynamic.threadpool.common.web.base.Results; import com.github.dynamic.threadpool.common.web.base.Results;
import io.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemQueryReqDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemRespDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemRespDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemSaveReqDTO;
import io.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO; import com.github.dynamic.threadpool.config.model.biz.item.ItemUpdateReqDTO;
import io.dynamic.threadpool.config.service.biz.ItemService; import com.github.dynamic.threadpool.config.service.biz.ItemService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;

@ -1,14 +1,14 @@
package io.dynamic.threadpool.console.controller; package com.github.dynamic.threadpool.console.controller;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.web.base.Result; import com.github.dynamic.threadpool.common.web.base.Result;
import io.dynamic.threadpool.common.web.base.Results; import com.github.dynamic.threadpool.common.web.base.Results;
import io.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantQueryReqDTO;
import io.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantRespDTO;
import io.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantSaveReqDTO;
import io.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO; import com.github.dynamic.threadpool.config.model.biz.tenant.TenantUpdateReqDTO;
import io.dynamic.threadpool.config.service.biz.TenantService; import com.github.dynamic.threadpool.config.service.biz.TenantService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;

@ -1,13 +1,13 @@
package io.dynamic.threadpool.console.controller; package com.github.dynamic.threadpool.console.controller;
import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.metadata.IPage;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.web.base.Result; import com.github.dynamic.threadpool.common.web.base.Result;
import io.dynamic.threadpool.common.web.base.Results; import com.github.dynamic.threadpool.common.web.base.Results;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolQueryReqDTO;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolRespDTO;
import io.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO; import com.github.dynamic.threadpool.config.model.biz.threadpool.ThreadPoolSaveOrUpdateReqDTO;
import io.dynamic.threadpool.config.service.biz.ThreadPoolService; import com.github.dynamic.threadpool.config.service.biz.ThreadPoolService;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;

@ -4,7 +4,7 @@
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>
<parent> <parent>
<groupId>io.dynamic-threadpool</groupId> <groupId>com.github.dynamic-threadpool</groupId>
<artifactId>parent</artifactId> <artifactId>parent</artifactId>
<version>1.0.0-SNAPSHOT</version> <version>1.0.0-SNAPSHOT</version>
</parent> </parent>
@ -46,7 +46,7 @@
</dependency> </dependency>
<dependency> <dependency>
<groupId>io.dynamic-threadpool</groupId> <groupId>com.github.dynamic-threadpool</groupId>
<artifactId>dynamic-threadpool-common</artifactId> <artifactId>dynamic-threadpool-common</artifactId>
</dependency> </dependency>

@ -1,8 +1,8 @@
package io.dynamic.threadpool.starter.common; package com.github.dynamic.threadpool.starter.common;
import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum; import com.github.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum;
import io.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder; import com.github.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder;
import io.dynamic.threadpool.starter.toolkit.thread.RejectedPolicies; import com.github.dynamic.threadpool.starter.toolkit.thread.RejectedPolicies;
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;

@ -1,13 +1,13 @@
package io.dynamic.threadpool.starter.config; package com.github.dynamic.threadpool.starter.config;
import io.dynamic.threadpool.common.config.ApplicationContextHolder; import com.github.dynamic.threadpool.starter.core.ThreadPoolBeanPostProcessor;
import io.dynamic.threadpool.starter.controller.PoolRunStateController; import com.github.dynamic.threadpool.starter.core.ThreadPoolOperation;
import io.dynamic.threadpool.starter.core.ConfigService; import com.github.dynamic.threadpool.starter.enable.DynamicThreadPoolMarkerConfiguration;
import io.dynamic.threadpool.starter.core.ThreadPoolBeanPostProcessor; import com.github.dynamic.threadpool.common.config.ApplicationContextHolder;
import io.dynamic.threadpool.starter.core.ThreadPoolConfigService; import com.github.dynamic.threadpool.starter.controller.PoolRunStateController;
import io.dynamic.threadpool.starter.core.ThreadPoolOperation; import com.github.dynamic.threadpool.starter.core.ConfigService;
import io.dynamic.threadpool.starter.enable.DynamicThreadPoolMarkerConfiguration; import com.github.dynamic.threadpool.starter.core.ThreadPoolConfigService;
import io.dynamic.threadpool.starter.handler.ThreadPoolBannerHandler; import com.github.dynamic.threadpool.starter.handler.ThreadPoolBannerHandler;
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.config; package com.github.dynamic.threadpool.starter.config;
import lombok.Getter; import lombok.Getter;
import lombok.Setter; import lombok.Setter;

@ -1,6 +1,6 @@
package io.dynamic.threadpool.starter.config; package com.github.dynamic.threadpool.starter.config;
import io.dynamic.threadpool.starter.toolkit.HttpClientUtil; import com.github.dynamic.threadpool.starter.toolkit.HttpClientUtil;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient; import okhttp3.OkHttpClient;

@ -1,9 +1,9 @@
package io.dynamic.threadpool.starter.controller; package com.github.dynamic.threadpool.starter.controller;
import io.dynamic.threadpool.common.model.PoolRunStateInfo; import com.github.dynamic.threadpool.starter.handler.ThreadPoolRunStateHandler;
import io.dynamic.threadpool.common.web.base.Result; import com.github.dynamic.threadpool.common.model.PoolRunStateInfo;
import io.dynamic.threadpool.common.web.base.Results; import com.github.dynamic.threadpool.common.web.base.Result;
import io.dynamic.threadpool.starter.handler.ThreadPoolRunStateHandler; import com.github.dynamic.threadpool.common.web.base.Results;
import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;

@ -1,9 +1,9 @@
package io.dynamic.threadpool.starter.core; package com.github.dynamic.threadpool.starter.core;
import io.dynamic.threadpool.common.toolkit.ContentUtil; import com.github.dynamic.threadpool.starter.wrap.ManagerListenerWrap;
import io.dynamic.threadpool.common.toolkit.Md5Util; import com.github.dynamic.threadpool.common.toolkit.ContentUtil;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.toolkit.Md5Util;
import io.dynamic.threadpool.starter.wrap.ManagerListenerWrap; import com.github.dynamic.threadpool.common.constant.Constants;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArrayList;

@ -1,13 +1,13 @@
package io.dynamic.threadpool.starter.core; package com.github.dynamic.threadpool.starter.core;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.model.PoolParameterInfo; import com.github.dynamic.threadpool.common.model.PoolParameterInfo;
import io.dynamic.threadpool.common.toolkit.ContentUtil; import com.github.dynamic.threadpool.common.toolkit.ContentUtil;
import io.dynamic.threadpool.common.toolkit.GroupKey; import com.github.dynamic.threadpool.common.toolkit.GroupKey;
import io.dynamic.threadpool.common.web.base.Result; import com.github.dynamic.threadpool.common.web.base.Result;
import io.dynamic.threadpool.starter.remote.HttpAgent; import com.github.dynamic.threadpool.starter.remote.HttpAgent;
import lombok.SneakyThrows; import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
@ -21,8 +21,8 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import static io.dynamic.threadpool.common.constant.Constants.LINE_SEPARATOR; import static com.github.dynamic.threadpool.common.constant.Constants.LINE_SEPARATOR;
import static io.dynamic.threadpool.common.constant.Constants.WORD_SEPARATOR; import static com.github.dynamic.threadpool.common.constant.Constants.WORD_SEPARATOR;
/** /**
* *

@ -1,7 +1,7 @@
package io.dynamic.threadpool.starter.core; package com.github.dynamic.threadpool.starter.core;
import io.dynamic.threadpool.starter.wrap.DynamicThreadPoolWrap; import com.github.dynamic.threadpool.starter.wrap.DynamicThreadPoolWrap;
import io.dynamic.threadpool.common.model.PoolParameter; import com.github.dynamic.threadpool.common.model.PoolParameter;
import java.util.Map; import java.util.Map;
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentHashMap;

@ -1,4 +1,4 @@
package io.dynamic.threadpool.starter.core; package com.github.dynamic.threadpool.starter.core;
import java.util.concurrent.Executor; import java.util.concurrent.Executor;

@ -1,17 +1,17 @@
package io.dynamic.threadpool.starter.core; package com.github.dynamic.threadpool.starter.core;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import io.dynamic.threadpool.common.constant.Constants; import com.github.dynamic.threadpool.common.constant.Constants;
import io.dynamic.threadpool.common.model.PoolParameterInfo; import com.github.dynamic.threadpool.common.model.PoolParameterInfo;
import io.dynamic.threadpool.common.web.base.Result; import com.github.dynamic.threadpool.common.web.base.Result;
import io.dynamic.threadpool.starter.common.CommonThreadPool; import com.github.dynamic.threadpool.starter.common.CommonThreadPool;
import io.dynamic.threadpool.starter.config.DynamicThreadPoolProperties; import com.github.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import io.dynamic.threadpool.starter.remote.HttpAgent; import com.github.dynamic.threadpool.starter.remote.HttpAgent;
import io.dynamic.threadpool.starter.remote.ServerHttpAgent; import com.github.dynamic.threadpool.starter.remote.ServerHttpAgent;
import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum; import com.github.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum;
import io.dynamic.threadpool.starter.toolkit.thread.RejectedTypeEnum; import com.github.dynamic.threadpool.starter.toolkit.thread.RejectedTypeEnum;
import io.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder; import com.github.dynamic.threadpool.starter.toolkit.thread.ThreadPoolBuilder;
import io.dynamic.threadpool.starter.wrap.DynamicThreadPoolWrap; import com.github.dynamic.threadpool.starter.wrap.DynamicThreadPoolWrap;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeansException; import org.springframework.beans.BeansException;
import org.springframework.beans.factory.config.BeanPostProcessor; import org.springframework.beans.factory.config.BeanPostProcessor;

@ -1,8 +1,8 @@
package io.dynamic.threadpool.starter.core; package com.github.dynamic.threadpool.starter.core;
import io.dynamic.threadpool.starter.config.DynamicThreadPoolProperties; import com.github.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import io.dynamic.threadpool.starter.remote.HttpAgent; import com.github.dynamic.threadpool.starter.remote.HttpAgent;
import io.dynamic.threadpool.starter.remote.ServerHttpAgent; import com.github.dynamic.threadpool.starter.remote.ServerHttpAgent;
import java.util.Arrays; import java.util.Arrays;

@ -1,10 +1,10 @@
package io.dynamic.threadpool.starter.core; package com.github.dynamic.threadpool.starter.core;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import io.dynamic.threadpool.common.model.PoolParameterInfo; import com.github.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum;
import io.dynamic.threadpool.starter.toolkit.thread.QueueTypeEnum; import com.github.dynamic.threadpool.starter.toolkit.thread.ResizableCapacityLinkedBlockIngQueue;
import io.dynamic.threadpool.starter.toolkit.thread.RejectedTypeEnum; import com.github.dynamic.threadpool.common.model.PoolParameterInfo;
import io.dynamic.threadpool.starter.toolkit.thread.ResizableCapacityLinkedBlockIngQueue; import com.github.dynamic.threadpool.starter.toolkit.thread.RejectedTypeEnum;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import java.util.Objects; import java.util.Objects;

@ -1,6 +1,6 @@
package io.dynamic.threadpool.starter.core; package com.github.dynamic.threadpool.starter.core;
import io.dynamic.threadpool.starter.config.DynamicThreadPoolProperties; import com.github.dynamic.threadpool.starter.config.DynamicThreadPoolProperties;
import java.util.concurrent.Executor; import java.util.concurrent.Executor;

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

@ -1,4 +1,4 @@
package io.dynamic.threadpool.starter.enable; package com.github.dynamic.threadpool.starter.enable;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;

Some files were not shown because too many files have changed in this diff Show More

Loading…
Cancel
Save