zoukankan      html  css  js  c++  java
  • CompletableFuture代码示例

    List<CompletableFuture<String>> checkFutures = checkFilterList.parallelStream().map(checkFilter-> 
                        CompletableFuture.supplyAsync(() -> {
                            String checkType = checkFilter.obtainCheckType();
                            if (!resultMap.containsKey(checkType)) {
                                StringBuilder strBuilder = new StringBuilder();
                                resultMap.put(checkType, strBuilder);
                            }
                            StringBuilder resultSaver = resultMap.get(checkType);
                            String result = StringConstant.JOB_SUCCESS;
                            try {
                                result = checkFilter.doFilter(sourceMediaDup, targetMediaDup, tableMappingInfo);
                            } catch (Exception e) {
                                logger.error("checkInputValid error happend", e);
                                result = StringConstant.JOB_ERROR;
                            }
                            if (!Objects.equals(result, StringConstant.JOB_SUCCESS)) {
                                resultSaver.append(result).append("
    ");
                            }
                            return StringConstant.JOB_SUCCESS;
                        }, myExecutor).exceptionally(e -> {
                            logger.error("{} checkInputValid error", checkFilter.obtainCheckName(), e); //java.lang.ArithmeticException: / by zero
                            return "";
                        })).collect(Collectors.toList());
                    checkFutures.stream().map(CompletableFuture::join).collect(Collectors.toList()); 
  • 相关阅读:
    小小c#算法题
    .net中值类型、引用类型理解的c#代码示例
    小小c#算法题
    小小c#算法题
    小小c#算法题
    小小c#算法题
    python 正则表达式(一)
    python string 文本常量和模版
    centos6安装redis
    sqoop命令总结
  • 原文地址:https://www.cnblogs.com/juniorMa/p/14341731.html
Copyright © 2011-2022 走看看