码农知识堂 - 1000bd
  •   Python
  •   PHP
  •   JS/TS
  •   JAVA
  •   C/C++
  •   C#
  •   GO
  •   Kotlin
  •   Swift
  • 通过ExecutorService、Callable、Future实现有返回结果的多线程来处理有轮询业务


            开发中碰到类似受理业务等相关接口一般都是异步获取结果,要么就属于异步回调后再下一步处理业务,要么就定时轮询查询接口获取结果再下一步处理业务流程;此次碰到类似接口是没有异步回调处理,协同系统只提供业务受理接口及查询结果接口,不明确什么时间会有处理完成结果,仅给大概1分钟时间,只好使用轮询的方式查询结果 ;通过ExecutorService、Callable、Future实现有返回结果的多线程来轮询结果判断是否再下一步业务。

    相关代码片段:

    public Map queryRetry(PayOrder payOrder) {
            final ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
            // 总共轮询查询时间,单位秒
            final int queryTime = 60;
            // 间隔时间,单位秒
            final int queryPeriod = 5;

            // 使用ExecutorService、Callable、Future实现有返回结果的多线程。
            Callable queryCallable = () -> {
                Thread.sleep(queryPeriod * 1000);
                return this.orderInfoQuery(payOrder);
            };
            //返回map
            Map map = Maps.newHashMap();
            int n = queryTime / queryPeriod;
            for (int i = 0; i <= n; i++) {
                Future future = service.submit(queryCallable);
                try {
                    //获取map结果
                    map = (Map)future.get();
                    log.info(i + "次轮询查询返参>>" + map);
                    //code 编码为0成功
                    if ("0".equals(map.get("code"))) {
                        break;
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            // 停止线程池
            service.shutdownNow();
            return map;
        }

  • 相关阅读:
    C++ 继承
    PHP 如何创建一个 composer 包 并在 项目中使用自己的 composer sdk 包
    【区块链 | Solidity】以太坊Solidity如何实现海量空投代币?
    尚优选项目流程&布局参数
    FPGA从入门到精通(二十)SignalTapII
    python科研绘图:帕累托图(Pareto chart)
    2022-06-25 jvm调优 1
    神经网络训练样本 加权,神经网络训练模型描述
    艾瑞泽5汽车电子控制单元CAN通信数据读写车辆网络系统交互接口
    arthas 使用教程
  • 原文地址:https://blog.csdn.net/dengxw00/article/details/132891258
    • 最新文章
    • 攻防演习之三天拿下官网站群
      数据安全治理学习——前期安全规划和安全管理体系建设
      企业安全 | 企业内一次钓鱼演练准备过程
      内网渗透测试 | Kerberos协议及其部分攻击手法
      0day的产生 | 不懂代码的"代码审计"
      安装scrcpy-client模块av模块异常,环境问题解决方案
      leetcode hot100【LeetCode 279. 完全平方数】java实现
      OpenWrt下安装Mosquitto
      AnatoMask论文汇总
      【AI日记】24.11.01 LangChain、openai api和github copilot
    • 热门文章
    • 十款代码表白小特效 一个比一个浪漫 赶紧收藏起来吧!!!
      奉劝各位学弟学妹们,该打造你的技术影响力了!
      五年了,我在 CSDN 的两个一百万。
      Java俄罗斯方块,老程序员花了一个周末,连接中学年代!
      面试官都震惊,你这网络基础可以啊!
      你真的会用百度吗?我不信 — 那些不为人知的搜索引擎语法
      心情不好的时候,用 Python 画棵樱花树送给自己吧
      通宵一晚做出来的一款类似CS的第一人称射击游戏Demo!原来做游戏也不是很难,连憨憨学妹都学会了!
      13 万字 C 语言从入门到精通保姆级教程2021 年版
      10行代码集2000张美女图,Python爬虫120例,再上征途
    Copyright © 2022 侵权请联系2656653265@qq.com    京ICP备2022015340号-1
    正则表达式工具 cron表达式工具 密码生成工具

    京公网安备 11010502049817号