fix RTDmpFetch bug

src/main/java/mobvista/dmp/datasource/rtdmp/RTDmpFetch.java

@@ -3,6 +3,7 @@ package mobvista.dmp.datasource.rtdmp;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import mobvista.dmp.common.Constants;
 import mobvista.dmp.datasource.rtdmp.entity.Tuple;
 import mobvista.dmp.util.*;
@@ -30,6 +31,7 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.concurrent.*;
 
 /**
  * @package: mobvista.dmp.datasource.rtdmp
@@ -80,10 +82,23 @@ public class RTDmpFetch {
         String part = DateUtil.format(DateUtil.parse(update_time_end, "yyyy-MM-dd HH:mm:ss"), "yyyyMMddHH");
         JSONArray jsonArray = ruleAudienceInfo(update_time_start, update_time_end);
         jsonArray.sort(Comparator.comparing(obj -> ((JSONObject) obj).getIntValue("id")));
+
+        ThreadFactory threadFactory = new ThreadFactoryBuilder()
+                .setNameFormat("RTDmpFetch-%d").build();
+
+        ExecutorService pool = new ThreadPoolExecutor(5, 10,
+                120L, TimeUnit.MILLISECONDS,
+                new LinkedBlockingQueue<>(64), threadFactory, new ThreadPoolExecutor.AbortPolicy());
+
         for (int i = 0; i < jsonArray.size(); i++) {
-            JSONObject audienceObject = jsonArray.getJSONObject(i);
+            int finalI = i;
+            pool.execute(() -> {
+                JSONObject audienceObject = jsonArray.getJSONObject(finalI);
                 doFetch(audienceObject, part);
+            });
         }
+
+        pool.shutdown();
     }
 
     private static void doFetch(JSONObject audienceObject, String part) {