perf[orm]: entity cache使用相同的线程去更新

event/src/main/java/com/zfoo/event/manager/EventBus.java

@@ -91,6 +91,10 @@ public abstract class EventBus {
         return executors[RandomUtils.randomInt(EXECUTORS_SIZE)];
     }
 
+    public static Executor asyncExecute(int hashcode) {
+        return executors[Math.abs(hashcode % EXECUTORS_SIZE)];
+    }
+
     private static void doSubmit(IEvent event, List<IEventReceiver> receiverList) {
         for (var receiver : receiverList) {
             try {

orm/src/main/java/com/zfoo/orm/model/persister/CronOrmPersister.java

@@ -78,7 +78,7 @@ public class CronOrmPersister extends AbstractOrmPersister {
                 @Override
                 public void run() {
                     if (!OrmContext.isStop()) {
-                        EventBus.asyncExecute().execute(new Runnable() {
+                        EventBus.asyncExecute(entityDef.getClazz().hashCode()).execute(new Runnable() {
                             @Override
                             public void run() {
                                 entityCaches.persistAll();

orm/src/main/java/com/zfoo/orm/model/persister/TimeOrmPersister.java

@@ -47,7 +47,7 @@ public class TimeOrmPersister extends AbstractOrmPersister {
             @Override
             public void run() {
                 if (!OrmContext.isStop()) {
-                    EventBus.asyncExecute().execute(new Runnable() {
+                    EventBus.asyncExecute(entityDef.getClazz().hashCode()).execute(new Runnable() {
                         @Override
                         public void run() {
                             entityCaches.persistAll();