/**

* @param reqList

* @param localUrl

* @param type? ? 0:攝像頭抓拍

* @return

*/

public static ListcapturePic(List reqList, String localUrl, Integer type)throws ExecutionException, InterruptedException {

List> capList =new ArrayList<>();

? ? List list =new ArrayList<>();

? ? if (CollectionUtils.isNotEmpty(reqList)) {

for (MdCameraInfoReq req : reqList) {

String picUrl ="";

? ? ? ? ? ? if (Consts.INT_ZERO.equals(type)) {

//開啟線程

? ? ? ? ? ? ? ? CompletableFuture future = CompletableFuture.supplyAsync(() -> {

return CapturePicUtils.capturePic(req.getIp(), req.getPort(), req.getUserName(), req.getPwd(), req.getChannel(), localUrl);

? ? ? ? ? ? ? ? }, executorFinishWeighImgService);

? ? ? ? ? ? ? ? //抓圖線程list

? ? ? ? ? ? ? ? capList.add(future);

? ? ? ? ? ? }else {

picUrl = CapturePicUtils.captureNvrPic(req, localUrl);

? ? ? ? ? ? }

if (StringUtils.isNotBlank(picUrl)) {

list.add(picUrl);

? ? ? ? ? ? }

}

}

List captures =new ArrayList<>();

? ? CompletableFuture completableFuture = CompletableFuture.allOf(capList.toArray(new CompletableFuture[capList.size()]));

? ? //阻塞，直到所有任務結束

? ? completableFuture.join();

? ? CompletableFuture> captureList = completableFuture.thenApply(returnFuture -> {

capList.forEach(future -> {

try {

if (Objects.nonNull(future.get(5, TimeUnit.SECONDS))) {

captures.add(future.get(5, TimeUnit.SECONDS));

? ? ? ? ? ? ? ? }else {

log.error("獲取數(shù)據(jù)超時");

? ? ? ? ? ? ? ? }

}catch (InterruptedException e) {

log.error("終端異常：{}", e);

? ? ? ? ? ? }catch (ExecutionException e) {

log.error("capturePic執(zhí)行異常：{}", e);

? ? ? ? ? ? }catch (TimeoutException e) {

log.error("capturePic超時：{}", e);

? ? ? ? ? ? }

});

? ? ? ? return captures;

? ? });

? ? List baseList = captureList.get().stream().collect(Collectors.toList());

? ? return baseList;

}