微调

Author: zhongxunking

common/src/main/java/org/bekit/common/method/MethodExecutor.java

@@ -16,7 +16,7 @@
  */
 public abstract class MethodExecutor {
     // 目标方法
-    private Method targetMethod;
+    private final Method targetMethod;
 
     public MethodExecutor(Method targetMethod) {
         this.targetMethod = targetMethod;

event/src/main/java/org/bekit/event/EventPublisher.java

@@ -12,12 +12,10 @@
  * 事件发布器
  */
 public interface EventPublisher {
-
     /**
      * 发布事件
      *
      * @param event 事件
      */
     void publish(Object event);
-
 }

event/src/main/java/org/bekit/event/annotation/BizListener.java

@@ -22,7 +22,6 @@
 @Retention(RetentionPolicy.RUNTIME)
 @Listener(type = BizListenerType.class)
 public @interface BizListener {
-
     /**
      * 优先级
      * （具体执行顺序需要结合@Listen注解的priorityAsc属性共同决定）

event/src/main/java/org/bekit/event/annotation/Listen.java

@@ -21,7 +21,6 @@
 @Retention(RetentionPolicy.RUNTIME)
 @org.bekit.event.annotation.listener.Listen(resolver = ClassListenResolver.class)
 public @interface Listen {
-
     /**
      * 是否按照优先级升序
      * <p>

event/src/main/java/org/bekit/event/annotation/listener/Listen.java

@@ -19,7 +19,6 @@
 @Target(ElementType.ANNOTATION_TYPE)
 @Retention(RetentionPolicy.RUNTIME)
 public @interface Listen {
-
     /**
      * 监听解决器
      */

event/src/main/java/org/bekit/event/annotation/listener/Listener.java

@@ -21,7 +21,6 @@
 @Retention(RetentionPolicy.RUNTIME)
 @Component
 public @interface Listener {
-
     /**
      * 类型
      */

event/src/main/java/org/bekit/event/boot/EventBusConfiguration.java

@@ -25,7 +25,6 @@
 @Configuration
 @Import({EventBusesHolder.class, ListenersHolder.class})
 public class EventBusConfiguration {
-
     // 业务事件发布器
     @Bean
     @DependsOn("org.bekit.event.bus.EventBusesHolder")      // 保证出现循环引用时不会出错

event/src/main/java/org/bekit/event/bus/EventBus.java

@@ -18,11 +18,11 @@
  */
 public class EventBus {
     // 监听器执行器
-    private List<ListenerExecutor> listenerExecutors = new ArrayList<>();
+    private final List<ListenerExecutor> listenerExecutors = new ArrayList<>();
     // 监听器执行器缓存（key：事件类型）
     private Map<Object, List<ListenerExecutor>> listenerExecutorsCache = new HashMap<>();
     // 事件类型解决器
-    private EventTypeResolver resolver;
+    private final EventTypeResolver resolver;
 
     public EventBus(EventTypeResolver resolver) {
         this.resolver = resolver;
@@ -59,7 +59,7 @@ public void dispatch(Object event) throws Throwable {
 
     // 刷新监听器缓存
     private void refreshListenerCache() {
-        listenerExecutorsCache = new HashMap<>();
+        Map<Object, List<ListenerExecutor>> cache = new HashMap<>();
         // 获取本总线所有的事件类型
         Set<Object> eventTypes = new HashSet<>();
         for (ListenerExecutor listenerExecutor : listenerExecutors) {
@@ -84,7 +84,9 @@ private void refreshListenerCache() {
                 }
             }
             // 设置缓存
-            listenerExecutorsCache.put(eventType, theListenerExecutors);
+            cache.put(eventType, theListenerExecutors);
         }
+        // 刷新缓存
+        listenerExecutorsCache = cache;
     }
 }

event/src/main/java/org/bekit/event/bus/EventBusesHolder.java

@@ -27,7 +27,7 @@ public class EventBusesHolder {
     @Autowired
     private ListenersHolder listenersHolder;
     // 事件总线Map（key：总线类型）
-    private Map<Class, EventBus> eventBusMap = new HashMap<>();
+    private final Map<Class, EventBus> eventBusMap = new HashMap<>();
 
     // 初始化（根据监听器类型创建相应类型的事件总线，spring自动执行）
     @PostConstruct

event/src/main/java/org/bekit/event/extension/EventTypeResolver.java

@@ -12,7 +12,6 @@
  * 事件类型解决器
  */
 public interface EventTypeResolver {
-
     /**
      * 根据事件得到对应的事件类型
      *