nepxion / eventbus Goto Github PK

Contributors

Stargazers

Forkers

xiaomaoguai gspandy blacktree jackykang007 weizai118 young0704 liujiafeng622 zhoudaqing widon azkoss awei0916 yj2006062 lingling1420q ryanlilib tengwj xiaode123 ciweigg2 joyzloudly charles2mx hehozengming luchao0111 limengcanyu dystudio mikeyy88 tgstriver gerryyuan godtroop-github cxntsh kangzhenkang liaomengge iikspiral javawmw jiji87432 nathangary zwzsdy noway56 moa-oma xiaoqun zhangtao-sw

...
    static Subscriber create(EventBus bus, Object listener, Method method) {
        return (Subscriber)(isDeclaredThreadSafe(method) ? new Subscriber(bus, listener, method) : new Subscriber.SynchronizedSubscriber(bus, listener, method));
    }
...
    private static boolean isDeclaredThreadSafe(Method method) {
        return method.getAnnotation(AllowConcurrentEvents.class) != null;
    }

    @VisibleForTesting
    static final class SynchronizedSubscriber extends Subscriber {
        private SynchronizedSubscriber(EventBus bus, Object target, Method method) {
            super(bus, target, method, null);
        }

        void invokeSubscriberMethod(Object event) throws InvocationTargetException {
            synchronized(this) {
                super.invokeSubscriberMethod(event);
            }
        }
    }
...