并发采集

 iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/channel/http/collector/ihdb/HttpCollectorForIhd.java

@@ -52,7 +52,7 @@

    private static final String STA_TRUE = "true";

    private static final int GROUP_MAX_COUNT = 100;
    private static final int GROUP_MAX_COUNT = 60;

    private static final int MAX_WAIT = 30;

@@ -202,12 +202,10 @@
            CountDownLatch countDownLatch = new CountDownLatch(measurePointsCountGroup.size());
            for (Map.Entry<Integer, List<Object[]>> measurePointsItem : measurePointsCountGroup.entrySet()) {
                HttpApiEntity httpApi = this.getHttpApi(measurePointsItem.getValue().get(0)[0].toString());

                // 并发
                Thread.sleep(1000);
                Thread.sleep(100);
                threadPool.submit(new Task(httpApi.getUrl(), httpApi.getCode(), result, measurePointsItem.getValue(),
                        collectTime, countDownLatch));

                // 顺序
                //this.getByHtp(result, measurePointsItem.getValue(), collectTime);
            }