diff --git a/mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java b/mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java index 6dd9871..463f2b7 100644 --- a/mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java +++ b/mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java @@ -1,24 +1,24 @@ package com.abin.mallchat.common.common.factory; -import com.abin.mallchat.common.common.handler.MyUncaughtExceptionHandler; +import com.abin.mallchat.common.common.handler.GlobalUncaughtExceptionHandler; +import lombok.AllArgsConstructor; +import lombok.NoArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.scheduling.concurrent.CustomizableThreadFactory; import java.util.concurrent.ThreadFactory; @Slf4j +@AllArgsConstructor +@NoArgsConstructor public class MyThreadFactory implements ThreadFactory { private String name; - public MyThreadFactory(String name){ - this.name=name; - } - public MyThreadFactory(){} + @Override public Thread newThread(Runnable r) { Thread thread = new Thread(r); - thread.setUncaughtExceptionHandler(new MyUncaughtExceptionHandler(name)); + thread.setUncaughtExceptionHandler(new GlobalUncaughtExceptionHandler(name)); return thread; } } diff --git a/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java b/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java index 12dde06..319a715 100644 --- a/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java +++ b/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java @@ -1,17 +1,19 @@ package com.abin.mallchat.common.common.handler; +import lombok.AllArgsConstructor; +import lombok.NoArgsConstructor; import lombok.extern.slf4j.Slf4j; @Slf4j +@AllArgsConstructor +@NoArgsConstructor public class GlobalUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler { private String name; - public GlobalUncaughtExceptionHandler(){} - public GlobalUncaughtExceptionHandler(String name){ - this.name=name; - } + @Override public void uncaughtException(Thread t, Throwable e) { - log.error("current thread name is",t.getName()," is error[{}]",e); + log.error("线程池名称:[{}],错误信息如下:",name); + e.printStackTrace(); } } diff --git a/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/MyUncaughtExceptionHandler.java b/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/MyUncaughtExceptionHandler.java deleted file mode 100644 index 6348ca8..0000000 --- a/mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/MyUncaughtExceptionHandler.java +++ /dev/null @@ -1,19 +0,0 @@ -package com.abin.mallchat.common.common.handler; - -import lombok.AllArgsConstructor; -import lombok.NoArgsConstructor; -import lombok.extern.slf4j.Slf4j; - -@Slf4j -@AllArgsConstructor -@NoArgsConstructor -public class MyUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler { - private String name; - - @Override - public void uncaughtException(Thread t, Throwable e) { - log.error("线程池名称:[{}],错误信息如下:",name); - e.printStackTrace(); - } - -}