Upstream/Minestom
1
0
Fork 0
mirror of https://github.com/Minestom/Minestom.git synced 2025-01-20 07:02:32 +01:00
Code Issues Projects Releases Wiki Activity

Improve redirection performance

Browse Source
This commit is contained in:
TheMode 2021-06-04 10:07:46 +02:00
parent b979c9b624
commit 2872a25325
1 changed files with 23 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/main/java/net/minestom/server/event/EventNode.java
View File

@ -65,6 +65,7 @@ public class EventNode<T extends Event> {
}
private static final Map<Class<? extends Event>, EventFilter<Event, ?>> REDIRECTION_MAP = new ConcurrentHashMap<>();
private static final Map<Class<? extends Event>, List<EventFilter<Event, ?>>> REDIRECTION_CACHE = new ConcurrentHashMap<>();
private static void registerMapping(EventFilter<? extends Event, ?> filter) {
final var type = filter.getEventType();
@ -129,19 +130,16 @@ public class EventNode<T extends Event> {
// Process redirection
if (!redirectionMap.isEmpty()) {
// Loop through register redirection
REDIRECTION_MAP.forEach((aClass, f) -> {
if (aClass.isAssignableFrom(eventClass)) {
final Object handler = f.getHandler(event);
getRedirectionCache(event).forEach(redirectionFilter -> {
final Object handler = redirectionFilter.getHandler(event);
if (handler != null) {
final var node = redirectionMap.get(handler);
if (node != null) {
node.call(event);
}
}
}
});
}
// Process listener list
final var listeners = listenerMap.get(eventClass);
if (listeners != null && !listeners.isEmpty()) {
@ -290,4 +288,20 @@ public class EventNode<T extends Event> {
throw new IllegalStateException("Something wrong happened, listener count: " + result);
}
}
private static List<EventFilter<Event, ?>> getRedirectionCache(Event event) {
return REDIRECTION_CACHE.computeIfAbsent(event.getClass(),
aClass -> findFilters(event));
}
private static List<EventFilter<Event, ?>> findFilters(Event event) {
final var eventClass = event.getClass();
List<EventFilter<Event, ?>> filters = new ArrayList<>();
REDIRECTION_MAP.forEach((aClass, f) -> {
if (aClass.isAssignableFrom(eventClass)) {
filters.add(f);
}
});
return filters;
}
}