Исходник Простая система событий

RenderSystem · 13 Авг 2024

Что еще можно добавить или доработать ?

EventBus:

public class EventBus {

    private static final Map<Class<? extends Event>, Set<Listener<? extends Event>>> listeners = new HashMap<>();

    public static void setObjectStateForListener(Object object, boolean register) {
        Stream.of(object.getClass().getDeclaredFields())
                .filter(field -> field.getType().equals(Listener.class))
                .forEach(field -> {
                    boolean accessible = field.isAccessible();
                    try {
                        if (!accessible) {
                            field.setAccessible(!accessible);
                        }
                        Class<? extends Event> eventType = (Class<? extends Event>) ((ParameterizedType) field.getGenericType()).getActualTypeArguments()[0];
                        if (register) {
                            listeners.computeIfAbsent(eventType, _ -> new HashSet<>()).add((Listener<? extends Event>) field.get(object));
                        } else {
                            listeners.get(eventType).remove((Listener<? extends Event>) field.get(object));
                        }
                    } catch (IllegalAccessException e) {
                        throw new RuntimeException(e);
                    } finally {
                        if (accessible != field.isAccessible()) {
                            field.setAccessible(accessible);
                        }
                    }
                });
    }

    protected static Map<Class<? extends Event>, Set<Listener<? extends Event>>> getListeners() {
        return listeners;
    }
}

Event:

public class Event extends EventBus {

    private boolean cancel;

    public <E extends Event> E execute() {
        setCancel(false);
        Set<Listener<? extends Event>> listeners = getListeners().get(this.getClass());
        if (Objects.nonNull(listeners)) {
            listeners.stream()
                    .map(listener -> (Listener<E>) listener)
                    .forEach(listener -> listener.execute((E) this));
        }
        return (E) this;
    }

    public void setCancel(boolean cancel) {
        this.cancel = cancel;
    }

    public boolean isCancel() {
        return cancel;
    }
}

Listener:

@FunctionalInterface
public interface Listener<E extends Event> {

    void execute(E event);
}

W9DEXGG1 · 14 Авг 2024

off4zk · 14 Авг 2024

W9DEXGG1 написал(а):
Ss?

ss евент системы? ебанутый?

marksixson · 14 Авг 2024

off4zk написал(а):
ss евент системы? ебанутый?

АХАХААХАХХА, ОН НАВЕРНОЕ ПОДУМАЛ ТИПА СОБИТИЯ ДЛЯ schedules

thentN · 14 Авг 2024

W9DEXGG1 написал(а):
Ss?

Хз тут максимум в сс фотку вантуза поставить можно

Joker33285 · 14 Авг 2024

thentN написал(а):
Хз тут максимум в сс фотку вантуза поставить можно

скибиди туалеты атакуют ура!

lascdre · 14 Авг 2024

RenderSystem написал(а):

Что еще можно добавить или доработать ?

EventBus:

public class EventBus {

    private static final Map<Class<? extends Event>, Set<Listener<? extends Event>>> listeners = new HashMap<>();

    public static void setObjectStateForListener(Object object, boolean register) {
        Stream.of(object.getClass().getDeclaredFields())
                .filter(field -> field.getType().equals(Listener.class))
                .forEach(field -> {
                    boolean accessible = field.isAccessible();
                    try {
                        if (!accessible) {
                            field.setAccessible(!accessible);
                        }
                        Class<? extends Event> eventType = (Class<? extends Event>) ((ParameterizedType) field.getGenericType()).getActualTypeArguments()[0];
                        if (register) {
                            listeners.computeIfAbsent(eventType, _ -> new HashSet<>()).add((Listener<? extends Event>) field.get(object));
                        } else {
                            listeners.get(eventType).remove((Listener<? extends Event>) field.get(object));
                        }
                    } catch (IllegalAccessException e) {
                        throw new RuntimeException(e);
                    } finally {
                        if (accessible != field.isAccessible()) {
                            field.setAccessible(accessible);
                        }
                    }
                });
    }

    protected static Map<Class<? extends Event>, Set<Listener<? extends Event>>> getListeners() {
        return listeners;
    }
}

Event:

public class Event extends EventBus {

    private boolean cancel;

    public <E extends Event> E execute() {
        setCancel(false);
        Set<Listener<? extends Event>> listeners = getListeners().get(this.getClass());
        if (Objects.nonNull(listeners)) {
            listeners.stream()
                    .map(listener -> (Listener<E>) listener)
                    .forEach(listener -> listener.execute((E) this));
        }
        return (E) this;
    }

    public void setCancel(boolean cancel) {
        this.cancel = cancel;
    }

    public boolean isCancel() {
        return cancel;
    }
}

Listener:

@FunctionalInterface
public interface Listener<E extends Event> {

    void execute(E event);
}

говнокода бы поменьше, вот че предложить могу

RenderSystem · 14 Авг 2024

lascdre написал(а):
говнокода бы поменьше, вот че предложить могу

Например ?

lascdre · 14 Авг 2024

RenderSystem написал(а):
Например ?

мне лень вчитываться в весь этот код, но говнокод тут имеется это очевидно, сделай попроще и читабельней..
примерно такую же систему событий я писал полгода назад и поэтому знаю, что пишу

OXXXYMlRON · 14 Авг 2024

lascdre написал(а):
мне лень вчитываться в весь этот код, но говнокод тут имеется это очевидно, сделай попроще и читабельней..
примерно такую же систему событий я писал полгода назад и поэтому знаю, что пишу

а конкретнее? в джаве не шарю, но код выглядит чисто.. если есть какой то синтаксис покруче - показывай, ёпта

Joker33285 · 14 Авг 2024

OXXXYMlRON написал(а):
а конкретнее? в джаве не шарю, но код выглядит чисто.. если есть какой то синтаксис покруче - показывай, ёпта

окси окси окси окси мирон пастер чего???!!!!!

OXXXYMlRON написал(а):
а конкретнее? в джаве не шарю, но код выглядит чисто.. если есть какой то синтаксис покруче - показывай, ёпта

окси окси окси окси

OXXXYMlRON · 14 Авг 2024

Joker33285 написал(а):
пастер

чего пастер то ёпта, я ни строчки джава кода в жизни не написал

Joker33285 · 14 Авг 2024

OXXXYMlRON написал(а):
чего пастер то ёпта, я ни строчки джава кода в жизни не написал

да шутка не обижайся окси окси окси мирон

lascdre · 14 Авг 2024

OXXXYMlRON написал(а):
но код выглядит чисто

RenderSystem написал(а):
Map<Class<? extends Event>, Set<Listener<? extends Event>>> listeners = new HashMap<>();

нууу...................

Teehi · 17 Авг 2024

RenderSystem написал(а):
Что еще можно добавить или доработать ?

Для просмотра содержимого вам необходимо авторизоваться.

Java:

public class EventBus {

    private static final Map<Class<?>, Set<Listener<?>>> listenerMap = Maps.newHashMap();

    public static void setObjectStateListener(Object object, boolean state) {
        processFields(object, _ -> true, state);
    }
    
    public static void setObjectStateListener(Object object, Class<? extends Event> event, boolean state) {
        processFields(object, field -> {
            Class<?> fieldEvent = (Class<?>) ((ParameterizedType) field.getGenericType()).getActualTypeArguments()[0];
            return event.equals(fieldEvent);
        }, state);
    }

    private static void processFields(Object object, Predicate<Field> fieldPredicate, boolean state) {
        Stream.of(object.getClass().getDeclaredFields())
                .filter(field -> field.getType().equals(Listener.class))
                .filter(fieldPredicate)
                .forEach(field -> {
                    boolean accessible = field.isAccessible();
                    try {
                        if (!accessible) {
                            field.setAccessible(true);
                        }
                        Listener<?> listener = (Listener<?>) field.get(object);
                        Class<?> event = (Class<?>) ((ParameterizedType) field.getGenericType()).getActualTypeArguments()[0];
                        if (state) {
                            listenerMap.computeIfAbsent(event, _ -> new HashSet<>()).add(listener);
                        } else {
                            Set<Listener<?>> listenerSet = listenerMap.get(event);
                            if (listenerSet != null && !listenerSet.isEmpty()) {
                                listenerSet.remove(listener);
                            }
                        }
                    } catch (Exception e) {
                        throw new RuntimeException(e);
                    } finally {
                        if (accessible != field.isAccessible()) {
                            field.setAccessible(accessible);
                        }
                    }
                });
    }


    public static Map<Class<?>, Set<Listener<?>>> getListenerMap() {
        return new HashMap<>(listenerMap);
    }
}