| | |
| | | this.waitAllFinishAndGetResult(pointList); |
| | | } |
| | | |
| | | public void waitAllFinishAndGetResult(List<YwPoint> dataList) throws |
| | | InterruptedException, ExecutionException { |
| | | int start = 0; |
| | | public void waitAllFinishAndGetResult(List<YwPoint> dataList) { |
| | | Date startTime = new Date(); |
| | | while (true) { |
| | | if (dataList.size() < start + 800) { |
| | | List<YwPoint> list = dataList.subList(start, dataList.size() - 1); |
| | | this.baseMapper.updatePoint(list); |
| | | break; |
| | | } else { |
| | | List<YwPoint> list = dataList.subList(start, start + 800); |
| | | this.baseMapper.updatePoint(list); |
| | | start += 800; |
| | | } |
| | | } |
| | | this.baseMapper.updatePoint(dataList); |
| | | Date endTime = new Date(); |
| | | log.error("总共耗时:" + (endTime.getTime() - startTime.getTime())); |
| | | } |