[Change] EventExecutor, BasicEventHandlerList 将方法检查过程分离出来;

[Add] NotAccepted 添加'拒绝接收'功能, 可指定某一符合事件接收要求的方法不接收事件;
[Add] SimpleEventHandler 增加ignoredEventHandler作为检查NotAccepted注解生效状况的方法;

Author: LamGC

src/main/java/net/lamgc/utils/event/BasicEventHandlerList.java

@@ -32,15 +32,8 @@ public void addEventHandler(Class<? extends EventHandler> eventHandler) throws I
 
         Method[] methods = eventHandler.getDeclaredMethods();
         for(Method method : methods){
-            int methodModifiers = method.getModifiers();
-            if(!Modifier.isPublic(methodModifiers)){
-                continue;
-            }
             Class<?>[] parameterTypes = method.getParameterTypes();
-            if(parameterTypes.length != 1){
-                continue;
-            }
-            if(!EventObject.class.isAssignableFrom(parameterTypes[0])){
+            if(!EventExecutor.checkMethod(method)) {
                 continue;
             }
             addEventHandlerMethod(parameterTypes[0].asSubclass(EventObject.class), method);

src/main/java/net/lamgc/utils/event/EventExecutor.java

@@ -153,18 +153,10 @@ public int executor(EventHandler handler, EventObject eventObject) throws Illega
         Method[] methods = handlerClass.getDeclaredMethods();
         int invokeCount = 0;
         for (Method method : methods) {
-            int methodModifiers = method.getModifiers();
-            if(!Modifier.isPublic(methodModifiers)){
+            if(!checkMethod(method, eventObject)) {
                 continue;
             }
-            Class<?>[] types = method.getParameterTypes();
-            if(types.length != 1){
-                continue;
-            }
-            if(!types[0].isAssignableFrom(eventObject.getClass())){
-                continue;
-            }
-
+            
             executeEvent(handler, eventObject, method, null);
             invokeCount++;
         }
@@ -350,6 +342,43 @@ public static void resendCurrentEvent() {
         }
     }
 
+    /**
+     * 检查指定方法是否为合法的事件接收方法
+     * @param method 待检查的方法
+     * @return 如果是合法的事件接收方法, 返回true
+     */
+    public static boolean checkMethod(Method method) {
+        return checkMethod(method, null);
+    }
+
+    /**
+     * 检查指定方法是否为合法的事件接收方法
+     * @param method 待检查的方法
+     * @param eventObject 指定的EventObject, 如没有指定可为null, 指定后, 将会检查继承性
+     * @return 如果是合法的事件接收方法, 返回true
+     */
+    private static boolean checkMethod(Method method, EventObject eventObject) {
+        int methodModifiers = method.getModifiers();
+        if(!Modifier.isPublic(methodModifiers)){
+            return false;
+        }
+        Class<?>[] types = method.getParameterTypes();
+        if(types.length != 1){
+            return false;
+        }
+        if(eventObject == null) {
+            if(!EventObject.class.isAssignableFrom(types[0])) {
+                return false;
+            }
+        } else {
+            if(!types[0].isAssignableFrom(eventObject.getClass())) {
+                return false;
+            }
+        }
+
+        return method.getDeclaredAnnotation(NotAccepted.class) == null;
+    }
+    
     @Override
     protected void finalize() {
         threadPoolExecutor.shutdownNow();

src/main/java/net/lamgc/utils/event/NotAccepted.java

@@ -0,0 +1,11 @@
+package net.lamgc.utils.event;
+
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+@Target({ElementType.METHOD})
+@Retention(RetentionPolicy.RUNTIME)
+public @interface NotAccepted {
+}

src/test/java/net/lamgc/utils/event/SimpleEventHandler.java

@@ -13,6 +13,12 @@ public void simpleEventHandler(SimpleEventObject event){
         event.invokeCount.incrementAndGet();
     }
 
+    @NotAccepted
+    public void ignoredEventHandler(SimpleEventObject event){
+        System.out.println(this.toString() + "." + flag + " - [" + event.errorCode + "] " + event.msg);
+        event.invokeCount.incrementAndGet();
+    }
+
     public void resendTestEvent(ResendEventObject event) {
         event.addInvokeCount();
         if(event.isFirstInvoke()) {