java实现异步调用

java实现异步调用1、使用线程池的逻辑实现异步调用packagecom.ourlang.dataextract.controller;importcom.google.common.util.concurrent.ThreadFactoryBuilder;importcom.ourlang.dataextract.common.CommonResult;importcom.ourlang.dataextract.service.ISInPatientListService;importorg.apach

大家好,又见面了,我是你们的朋友全栈君。

1、使用线程池的逻辑实现异步调用

package com.ourlang.dataextract.controller;

import com.google.common.util.concurrent.ThreadFactoryBuilder;
import com.ourlang.dataextract.common.CommonResult;
import com.ourlang.dataextract.service.ISInPatientListService;
import org.apache.tomcat.util.threads.ThreadPoolExecutor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.TimeUnit;

/** * 异步调用方法 * <p> * https://github.com/ourlang * </p> * * @author ourlang */
@RestController
public class AsynCallController { 
   

    private final ISInPatientListService inPatientListService;

    @Autowired
    public AsynCallController(ISInPatientListService inPatientListService) { 
   
        this.inPatientListService = inPatientListService;
    }

    /** * 创建线程池 实现异步调用方法 * @param serialNumber 住院号 * @param itemIds 需要的导入的项目ID集合用逗号(`,`)隔开 */
    private void createThead(String serialNumber, String itemIds) { 
   
        ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("demo-pool-%d").build();
        ExecutorService singleThreadPool = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
        //异步执行的方法
        singleThreadPool.execute(new PatientOtherData(serialNumber, itemIds));
        singleThreadPool.shutdown();

    }

    /** * */
    private class PatientOtherData implements Runnable { 
   
        private String serialNumber;
        private String itemIds;

        public PatientOtherData(String serialNumber, String itemIds) { 
   
            this.serialNumber = serialNumber;
            this.itemIds = itemIds;
        }

        @Override
        public void run() { 
   
            try { 
   
                //异步保存患者的其他数据
                savePatientOtherData(serialNumber, itemIds);
            } catch (Exception e) { 
   
                System.out.println(e);
            }

        }
    }


    /** * 保存患者的所有信息到我们的mysql数据库 * 保存患者主索引 (这张表暂时没有用) * isgPatientListService.savePrimaryIndexData(); * * @param itemIds 选择导入患者的哪些数据 * @param serialNumber 住院流水号 */
    @RequestMapping("/savePatientDataById")
    public CommonResult savePatientDataById(@RequestParam(name = "SERIAL_NUMBER") String serialNumber, @RequestParam(name = "itemIds") String itemIds) { 
   
        CommonResult commonResult = new CommonResult();
        commonResult.setCode(CommonResult.SUCCESS);
        commonResult.setMsg(CommonResult.SUCCESS_MESSAGE);
        // 1 2两点可以保证患者列表有数据
        // 1、保存患者就诊记录
        inPatientListService.saveInPatientList(serialNumber);
        System.out.println("serialNumber=" + serialNumber);
        System.out.println("itemIds=" + itemIds);
        //创建异步调用的线程池
        createThead(serialNumber, itemIds);

        return commonResult;
    }


    /** * 保存患者需要的其他数据 * * @param itemIds 需要的导入的项目ID集合用逗号(`,`)隔开 */
    public void savePatientOtherData(String serialNumber, String itemIds) throws Exception { 
   

        Thread.sleep(5000);
        System.out.println("savePatientOtherData--serialNumber=" + serialNumber);
        System.out.println("savePatientOtherData--itemIds=" + itemIds);
			//进行需要异步操作的一系列操作,比如存入数据库等等
    }
}

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/157323.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 铁通宽带dns地址(成都dns的服务器地址是多少)

    全国各地电信DNS见下:—————————————————————-北京DNS地址:202.96.199.133202.96.0.133202.106.0.20202.106.148.1202.97.16.195上海DNS地址:202.96.199.132202.96.199.133202.96.20

  • 浅析MOS管工作原理「建议收藏」

    浅析MOS管工作原理「建议收藏」MOS管分为N沟型MOS管和P沟型MOS管N沟型P沟型N沟型:漏极D接正极,源极S接负极,栅极G正电压时导电沟道建立,N沟道MOS管开始工作。P沟型:漏极D接负极,源极S接正极,栅极G负电压时

  • java从入门到精通_学习Java最好的10本书,从入门到精通

    java从入门到精通_学习Java最好的10本书,从入门到精通在当代,学习Java等编程课程的主要方式是视频资源。如果你想学,在网上五分钟之内就可以找到一堆学习视频,瞬间将你的硬盘填满。但是这些课程质量良莠不齐,对于小白来说,的确让人头痛不已。但是,书籍不同。对于书籍而言,它们都是出自业内大牛和资深的大学教授的精心编写,内容好坏与否,有很多同领域的网友都能帮你把关。所以说,如果你选对了学习的书籍,就可以不用担心自己在编程中,埋下错误的种子,同时还可以更深入的…

  • 考研数学二常用公式_考研数学写公式有分吗

    考研数学二常用公式_考研数学写公式有分吗面(体)积公式一元二次方程基础极坐标方程与直角坐标转换切线与法线方程因式分解公式阶乘与双阶乘函数的奇偶性排列组合等差数列等比数列常用数列前n项和不等式三角函数公式诱导公式平方关系两角和与差的三角函数积化和差公式和差化积公式倍角公式半角公式万能公式其他公式反三角函数恒等式极限相关公式数列极限递推式重要极限公式常用等价无穷小1^∞型导数相关公式导数定义微分定义连续,可导及可微关系一元函数多元函数导数四则运算复合函数求导反函数求导参数方程

  • windows平台连接EVE模拟器中网络设备两种方法

    windows平台连接EVE模拟器中网络设备两种方法windows平台下连接eve

  • java环境变量 的配置与详解(全网最详细教程)

    java环境变量 的配置与详解(全网最详细教程)笔者这学期开始学习java课程,学习java开发首先需要配置java运行环境变量。虽然上课老师也讲了如何配置java环境变量,可是笔者的同学还是有好多都不会配置,所以笔者最近配置了特别多次java环境变量。如下笔者详细解释从JDK安装到环境变量的装配。目录 JDK的下载与安装 配置java环境变量JAVA_HOME变量Path变量ClassPath变量classpath…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号