open-source/MallChat
1
0
Fork 0
mirror of https://github.com/zongzibinbin/MallChat.git synced 2026-03-13 21:53:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

认准该次提交,请直接忽略该功能其他次的提交

Browse Source
This commit is contained in:
风雨行
2023-05-31 00:10:38 +08:00
parent 1decddb6b1
commit e0963e88bd
3 changed files with 14 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
mallchat-common/src/main/java/com/abin/mallchat/common/common/factory/MyThreadFactory.java
View File

@@ -1,24 +1,24 @@
package com.abin.mallchat.common.common.factory; 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 lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.concurrent.CustomizableThreadFactory;
import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadFactory;
@Slf4j @Slf4j
@AllArgsConstructor
@NoArgsConstructor
public class MyThreadFactory implements ThreadFactory { public class MyThreadFactory implements ThreadFactory {
private String name; private String name;
public MyThreadFactory(String name){
this.name=name;
}
public MyThreadFactory(){}
@Override @Override
public Thread newThread(Runnable r) { public Thread newThread(Runnable r) {
Thread thread = new Thread(r); Thread thread = new Thread(r);
thread.setUncaughtExceptionHandler(new MyUncaughtExceptionHandler(name)); thread.setUncaughtExceptionHandler(new GlobalUncaughtExceptionHandler(name));
return thread; return thread;
} }
} }

12
mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/GlobalUncaughtExceptionHandler.java
View File

@@ -1,17 +1,19 @@
package com.abin.mallchat.common.common.handler; package com.abin.mallchat.common.common.handler;
import lombok.AllArgsConstructor;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@Slf4j @Slf4j
@AllArgsConstructor
@NoArgsConstructor
public class GlobalUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler { public class GlobalUncaughtExceptionHandler implements Thread.UncaughtExceptionHandler {
private String name; private String name;
public GlobalUncaughtExceptionHandler(){}
public GlobalUncaughtExceptionHandler(String name){
this.name=name;
}
@Override @Override
public void uncaughtException(Thread t, Throwable e) { public void uncaughtException(Thread t, Throwable e) {
log.error("current thread name is",t.getName()," is error[{}]",e); log.error("线程池名称：[{}],错误信息如下:",name);
e.printStackTrace();
} }
} }

19
mallchat-common/src/main/java/com/abin/mallchat/common/common/handler/MyUncaughtExceptionHandler.java
View File

@@ -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();
}
}