| | |
| | | |
| | | private static final int GROUP_MAX_COUNT = 300; |
| | | |
| | | private static final int MAX_WAIT = 30; |
| | | private static final int MAX_WAIT = 40; |
| | | |
| | | private static final String pattern = "yyyyMMddHHmm00"; |
| | | |
| | |
| | | for (Map.Entry<Integer, List<Object[]>> measurePointsItem : measurePointsCountGroup.entrySet()) { |
| | | HttpApiEntity httpApi = this.getHttpApi(measurePointsItem.getValue().get(0)[0].toString()); |
| | | // 并发 |
| | | Thread.sleep(1000); |
| | | Thread.sleep(500); |
| | | threadPool.submit(new Task(httpApi.getUrl(), httpApi.getCode(), result, measurePointsItem.getValue(), |
| | | collectTime, countDownLatch)); |
| | | // 顺序 |
| | |
| | | @Override |
| | | public void run(String params) { |
| | | // 0 0/1 * * * ? |
| | | logger.debug("CollectTaskNet60定时任务正在执行,参数为:{}", params); |
| | | logger.info("CollectTaskNet60定时任务正在执行,参数为:{}", params); |
| | | try { |
| | | Calendar calendar = Calendar.getInstance(); |
| | | calendar.set(Calendar.MILLISECOND, 0); |