From e0963e88bdbe40980347b7856f85909b34cebb0a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=A3=8E=E9=9B=A8=E8=A1=8C?= <2283550574@qq.com> Date: Wed, 31 May 2023 00:10:38 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=A4=E5=87=86=E8=AF=A5=E6=AC=A1=E6=8F=90?= =?UTF-8?q?=E4=BA=A4,=E8=AF=B7=E7=9B=B4=E6=8E=A5=E5=BF=BD=E7=95=A5?= =?UTF-8?q?=E8=AF=A5=E5=8A=9F=E8=83=BD=E5=85=B6=E4=BB=96=E6=AC=A1=E7=9A=84?= =?UTF-8?q?=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../common/factory/MyThreadFactory.java | 14 +++++++------- .../GlobalUncaughtExceptionHandler.java | 12 +++++++----- .../handler/MyUncaughtExceptionHandler.java | 19 ------------------- 3 files changed, 14 insertions(+), 31 deletions(-) delete mode 100644 mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/MyUncaughtExceptionHandler.java 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(); - } - -}