optimize event service close logic

Author: zeusoo001

framework/src/main/java/org/tron/core/services/event/BlockEventLoad.java

@@ -42,11 +42,16 @@ public void init() {
   }
 
   public void close() {
-    executor.shutdown();
-    logger.info("Event load service close.");
+    try {
+      load();
+      executor.shutdown();
+      logger.info("Event load service close.");
+    } catch (Exception e) {
+      logger.warn("Stop event load service fail. {}", e.getMessage());
+    }
   }
 
-  public void load() throws Exception {
+  public synchronized void load() throws Exception {
     long cacheHeadNum = BlockEventCache.getHead().getBlockId().getNum();
     long tmpNum =  manager.getDynamicPropertiesStore().getLatestBlockHeaderNumber();
     if (cacheHeadNum >= tmpNum) {

framework/src/main/java/org/tron/core/services/event/EventService.java

@@ -18,6 +18,9 @@ public class EventService {
   @Autowired
   private HistoryEventService historyEventService;
 
+  @Autowired
+  private SolidEventService solidEventService;
+
   @Autowired
   private Manager manager;
 
@@ -54,8 +57,9 @@ public void init()  {
   }
 
   public void close() {
-    realtimeEventService.close();
-    blockEventLoad.close();
     historyEventService.close();
+    blockEventLoad.close();
+    realtimeEventService.close();
+    solidEventService.close();
   }
 }

framework/src/main/java/org/tron/core/services/event/RealtimeEventService.java

@@ -45,6 +45,7 @@ public void init() {
   }
 
   public void close() {
+    work();
     executor.shutdown();
     logger.info("Realtime event service close.");
   }
@@ -57,7 +58,7 @@ public void add(Event event) {
     queue.offer(event);
   }
 
-  public void work() {
+  public synchronized void work() {
     while (queue.size() > 0) {
       Event event = queue.poll();
       flush(event.getBlockEvent(), event.isRemove());

framework/src/main/java/org/tron/core/services/event/SolidEventService.java

@@ -37,11 +37,12 @@ public void init() {
   }
 
   public void close() {
+    work();
     executor.shutdown();
     logger.info("Solid event service close.");
   }
 
-  public void work() {
+  public synchronized void work() {
     BlockCapsule.BlockId solidId = BlockEventCache.getSolidId();
     if (solidId.getNum() <= BlockEventCache.getSolidNum()) {
       return;