tps峰值接口重新调整

src/main/java/com/wuban/tron/explore/Bootstrapper.java

@@ -44,7 +44,7 @@ public class Bootstrapper {
     private ScheduledThreadPoolExecutor executorService;
 
     private void init() {
-        this.executorService = new ScheduledThreadPoolExecutor(2, new ThreadFactory() {
+        this.executorService = new ScheduledThreadPoolExecutor(1, new ThreadFactory() {
             private final AtomicInteger threadNumber = new AtomicInteger(1);
 
             @Override

src/main/java/com/wuban/tron/explore/fetch/Engine.java

@@ -69,29 +69,12 @@ public class Engine {
      */
     private ContractEventHandler contractEventHandler;
 
-    public static final int BLOCK_FETCHER_NUM = 2;
+    public static final int BLOCK_FETCHER_NUM = 1;
 
-    public static final int BALANCE_FETCHER_NUM = 2;
+    public static final int BALANCE_FETCHER_NUM = 1;
 
     public Engine(String name) {
         this.executor = new Executor(name);
-        this.monitor = new Thread(() -> {
-            while (!Thread.currentThread().isInterrupted()) {
-                try {
-                    Thread.sleep(1000);
-                    if (this.handler != null && this.handler.isShutdown()) {
-                        log.error("{} engine shutdown now restart ", name);
-                        reload();
-                    }
-                } catch (final InterruptedException e) {
-                    log.error("{} engine monitor interrupted ", name);
-                    break;
-                } catch (final Exception e) {
-                    log.error("{} engine monitor error ", name, e);
-                }
-            }
-        }, name.concat("_monitor"));
-        this.monitor.start();
     }
 
     public synchronized void start() {
@@ -102,9 +85,9 @@ public class Engine {
         this.handler = new BlockDataHandler();
         this.fetcher = new BlockDataFetcher(this.handler);
         this.executor.execute(this.handler);
-        for (int i = 0; i < BLOCK_FETCHER_NUM; i++) {
+        //for (int i = 0; i < BLOCK_FETCHER_NUM; i++) {
             this.executor.execute(this.fetcher);
-        }
+        //}
 
         /*
             账户余额抓取、处理
@@ -112,9 +95,9 @@ public class Engine {
         this.addressHandler = new AddressBalanceHandler();
         this.addressFetcher = new AddressBalanceFetcher(this.addressHandler);
         this.executor.execute(this.addressHandler);
-        for (int i = 0; i < BALANCE_FETCHER_NUM; i++) {
+        //for (int i = 0; i < BALANCE_FETCHER_NUM; i++) {
             this.executor.execute(this.addressFetcher);
-        }
+        //}
 
         /*
             统计数据抓取、处理

src/main/java/com/wuban/tron/explore/fetch/Executor.java

@@ -20,7 +20,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 @Slf4j
 public class Executor {
 
-    private static final int SIZE = 10;
+    private static final int SIZE = 6;
     private final List<AbstractJob> jobList = new ArrayList<>();
     private final String name;
     private ThreadPoolExecutor pool;

src/main/java/com/wuban/tron/explore/fetch/PersistThreadPoolV2.java

@@ -19,7 +19,7 @@ import java.util.concurrent.atomic.AtomicInteger;
 @Slf4j
 public class PersistThreadPoolV2 {
 
-    private static final int POLL_SIZE = 2;
+    private static final int POLL_SIZE = 1;
 
     private static PersistThreadPoolV2 instance;
     public final List<ThreadPoolExecutor> executors = new ArrayList<>(POLL_SIZE);