multiple thread

Author: wubin1

app/src/main/java/org/tron/eventplugin/app/PluginLauncher.java

@@ -34,7 +34,7 @@ public class PluginLauncher {
     private static final Logger logger = LoggerFactory.getLogger(PluginLauncher.class);
 
     public static void main(String[] args) {
-        String path = "/Users/tron/sourcecode/eventplugin/build/plugins/plugin-mongodb-1.0.0.zip";
+        String path = "/Users/tron/workplace/java-tronSubmit/java-tronUseSubmit/develop_event_subscribe/eventplugin/build/plugins/plugin-mongodb-1.0.0.zip";
 
         File dir = new File(path);
         // create the plugin manager

plugins/mongodbplugin/src/main/java/org/tron/eventplugin/MongodbSenderImpl.java

@@ -1,19 +1,25 @@
 package org.tron.eventplugin;
 import org.pf4j.util.StringUtils;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import java.util.*;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.util.concurrent.ListenableFuture;
 import org.tron.mongodb.MongoConfig;
 import org.tron.mongodb.MongoManager;
 import org.tron.mongodb.MongoTemplate;
 
 public class MongodbSenderImpl{
     private static MongodbSenderImpl instance = null;
     private static final Logger log = LoggerFactory.getLogger(MongodbSenderImpl.class);
+    ExecutorService service = Executors.newFixedThreadPool(8);
+    List<ListenableFuture<?>> futures = new ArrayList<>();
 
     private String serverAddress = "";
     private boolean loaded = false;
@@ -157,11 +163,14 @@ public void handleBlockEvent(Object data) {
         if (blockTopic == null || blockTopic.length() == 0){
             return;
         }
-
         MongoTemplate template = mongoTemplateMap.get(blockTopic);
-        if (Objects.nonNull(template)){
-            template.addEntity((String)data);
-            System.out.println("handleBlockEvent " + data);
+        if (Objects.nonNull(template)) {
+            service.execute(new Runnable() {
+                @Override
+                public void run() {
+                    template.addEntity((String)data);
+                }
+            });
         }
     }
 
@@ -170,9 +179,15 @@ public void handleTransactionTrigger(Object data) {
             return;
         }
 
+
         MongoTemplate template = mongoTemplateMap.get(transactionTopic);
-        if (Objects.nonNull(template)){
-            template.addEntity((String)data);
+        if (Objects.nonNull(template)) {
+            service.execute(new Runnable() {
+                @Override
+                public void run() {
+                    template.addEntity((String)data);
+                }
+            });
         }
     }
 
@@ -182,8 +197,13 @@ public void handleContractLogTrigger(Object data) {
         }
 
         MongoTemplate template = mongoTemplateMap.get(contractLogTopic);
-        if (Objects.nonNull(template)){
-            template.addEntity((String)data);
+        if (Objects.nonNull(template)) {
+            service.execute(new Runnable() {
+                @Override
+                public void run() {
+                    template.addEntity((String)data);
+                }
+            });
         }
     }
 
@@ -193,8 +213,13 @@ public void handleContractEventTrigger(Object data) {
         }
 
         MongoTemplate template = mongoTemplateMap.get(contractEventTopic);
-        if (Objects.nonNull(template)){
-            template.addEntity((String)data);
+        if (Objects.nonNull(template)) {
+            service.execute(new Runnable() {
+                @Override
+                public void run() {
+                    template.addEntity((String)data);
+                }
+            });
         }
     }
 

plugins/mongodbplugin/src/main/java/org/tron/mongodb/MongoTemplate.java

@@ -42,22 +42,22 @@ public void addEntity(String entity) {
         }
     }
 
-    public void addList(List<Document> documents) {
-        MongoCollection<Document> collection = getCollection();
-        collection.insertMany(documents);
-    }
-
-    public void addEntityList(List<Serializable> entities) {
+    public void addEntityList(List<String> entities) {
         MongoCollection<Document> collection = getCollection();
         List<Document> documents = new ArrayList<Document>();
         if (entities != null && !entities.isEmpty()) {
-            for (Serializable entity : entities) {
+            for (String entity : entities) {
                 documents.add(Converter.jsonStringToDocument(Converter.objectToJsonString(entity)));
             }
         }
         collection.insertMany(documents);
     }
 
+    public void addList(List<Document> documents) {
+        MongoCollection<Document> collection = getCollection();
+        collection.insertMany(documents);
+    }
+
     public long update(String updateColumn, Object updateValue, String whereColumn, Object whereValue) {
         MongoCollection<Document> collection = getCollection();
         UpdateResult result = collection.updateMany(Filters.eq(whereColumn, whereValue),