tiennm99/zfoo
1
0 Fork 0
mirror of https://github.com/tiennm99/zfoo.git synced 2026-10-13 22:16:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #112 from LucaLq/main

Browse Source 
perf[event]: support the reimplementation of exception handling
This commit is contained in:
godotg authored and GitHub committed 2024-06-12 12:25:37 +08:00
2 parents 11a9af5a1e 6e4b4f4205
commit 837b6d8e9d
1 file changed
+10 -5
Download Patch File Download Diff File Expand all files Collapse all files
event/src/main/java/com/zfoo/event/manager/EventBus.java
+10 -5
View File
@@ -34,7 +34,6 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.BiConsumer;
import java.util.function.Consumer;
/**
@@ -61,7 +60,10 @@ public abstract class EventBus {
/**
* event exception handler
*/
public static BiConsumer<IEventReceiver, IEvent> exceptionFunction = (receiver, event) -> {};
public static TriConsumer<IEventReceiver, IEvent, Throwable> exceptionFunction = (receiver, event, throwable) -> {
logger.error("bean:[{}] event:[{}] unhandled exception", receiver.getBean().getClass().getSimpleName(), event.getClass().getSimpleName(), throwable);
post(new ExceptionEvent(receiver, event, throwable));
};
/**
* event noReceiver handler
*/
@@ -127,12 +129,15 @@ public abstract class EventBus {
try {
receiver.invoke(event);
} catch (Throwable t) {
logger.error("bean:[{}] event:[{}] unhandled exception", receiver.getBean().getClass().getSimpleName(), event.getClass().getSimpleName(), t);
exceptionFunction.accept(receiver, event);
post(new ExceptionEvent(receiver, event, t));
exceptionFunction.accept(receiver, event, t);
}
}
@FunctionalInterface
public interface TriConsumer<T, U, V> {
void accept(T t, U u, V v);
}
public static void asyncExecute(Runnable runnable) {
asyncExecute(RandomUtils.randomInt(), runnable);
}