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)


相关推荐

  • java高并发 pdf_Java高并发编程详解 PDF 下载

    java高并发 pdf_Java高并发编程详解 PDF 下载推荐序一推荐序二推荐序三推荐序四前言第一部分多线程基础第1章快速认识线程1.1线程的介绍1.2快速创建并启动一个线程1.3线程的生命周期详解1.4线程的start方法剖析:模板设计模式在Thread中的应用1.5Runnable接口的引入以及策略模式在Thread中的使用1.6本章总结第2章深入理解Thread构造函数2.1线程的命名2.2线程的父子关系2.3Thread与…

  • 初始化磁盘_c++怎么初始化

    初始化磁盘_c++怎么初始化磁盘在联机后要初始化,同样也有两种方法,一种是调用IOCTL_DISK_CREATE_DISK,还有一种是调用WMI的Initialize方法。1.首先说说简单的WMI的方法:大致思路同博客:C++实现磁盘联机 先获取磁盘的id,然后执行无参数方法Initialize 核心模块代码如下:wchar_tmsftDiskObjectID[256];GetWMIMSFTDiskObjectId(…

  • 百度2015校园招聘前端笔试题(西安站)

    百度2015校园招聘前端笔试题(西安站)

    2021年12月15日
  • labelme实例分割标注_手机视频分割软件

    labelme实例分割标注_手机视频分割软件Labelme是一款经典的标注工具,支持目标检测、语义分割、实例分割等任务。今天针对分割任务的数据标注进行简单的介绍。开源项目地址:https://github.com/wkentaro/labelme

  • 协议脚本用什么软件写_脚本为什么叫脚本

    协议脚本用什么软件写_脚本为什么叫脚本性能测试准备首先确定软件的通讯协议、一般C/S架构采用的是socket协议基本流程建立与服务器短的链接 rc=lrs_create_socket(“socket0″,”TCP”,”localHost=0″,”RemoteHost=127.0.0.1:8080″,LrsLastArg); 注释:RemoteHost为服务器端地址和端口 链接是否成功,rc=…

  • python进阶(7)垃圾回收机制

    python进阶(7)垃圾回收机制前言现在的高级语言如java,c#等,都采用了垃圾回收机制,而不再像c,c++里,需要用户自己管理内存。自己管理内存及其自由,可以任意申请内存,但这如同一把双刃剑,可能会造成内存泄漏,空指针等bug

发表回复

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

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