用dw做的十二星座网站免费/计算机培训机构排名前十

用dw做的十二星座网站免费,计算机培训机构排名前十,简单的企业网站的主页,佛山市住房与城乡建设局网站在Java中使用Spring Boot实现异步请求和异步调用是一个常见的需求,可以提高应用程序的性能和响应能力。以下是实现这两种异步操作的基本方法: 一、异步请求(Asynchronous Request) 异步请求允许客户端发送请求后立即返回&#x…

在Java中使用Spring Boot实现异步请求和异步调用是一个常见的需求,可以提高应用程序的性能和响应能力。以下是实现这两种异步操作的基本方法:

一、异步请求(Asynchronous Request)

异步请求允许客户端发送请求后立即返回,而不需要等待服务器处理完成,异步调用允许在服务端异步执行方法,不阻塞主线程。

二、在 Spring Boot 中,实现异步调用主要有以下几种方法:
1. 使用 @Async 注解
步骤:
  1. 启用异步支持:在主类上添加 @EnableAsync
  2. 定义异步方法:在需要异步执行的方法上使用 @Async 注解。
  3. 自定义线程池(可选):提高异步任务的线程管理效率,以便异步方法能够在独立的线程中执行
示例代码:

主类:

package com.work;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;
@SpringBootApplication(scanBasePackages = {"com.work.*"})
@EnableAsync
//@EnableScheduling
public class SpringBootWorkApplication {public static void main(String[] args) {SpringApplication.run(SpringBootWorkApplication.class, args);}
}

异步方法:

package com.work.service;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
/*** 异步调用service* @author summer*/
@Service
@Slf4j
public class AsyncService {/*** 使用 @Async 注解 实现异步调用* taskExecutor为自定义线程池,指定自定义线程池* @return* @throws InterruptedException*/@Async("taskExecutor")public void async(){log.info("async异步任务开始: " + Thread.currentThread().getName());try {// 模拟耗时操作(实际工作中,此处写业务逻辑处理)  Thread.sleep(30000); } catch (InterruptedException e) {e.printStackTrace();}log.info("async异步任务完成");}
}
自定义线程池(可选):
package com.work.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/*** 自定义异步线程执行线程池* @author summer**/
@Configuration
public class ExecutorConfig {@Bean(name = "taskExecutor")public TaskExecutor  taskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(5);executor.setMaxPoolSize(10);executor.setQueueCapacity(50);executor.setThreadNamePrefix("TaskExecutor-");executor.initialize();return executor;}
}

@Async("taskExecutor") 中指定自定义线程池。

调用:
package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;/*** 测试异步执行Controller* @author summer**/
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {@Autowiredprivate AsyncService asyncService;@GetMapping("/async")public CommonResult<String> async() {asyncService.async();log.info("async异步任务调用成功");return CommonResult.success("async异步任务调用成功");}
}

异步方法休眠30秒,可以看到控制台打印的日志

线程池配置建议
  • CPU 密集型任务:建议核心线程数为 CPU 核心数的 n 倍,最大线程数为核心线程数的 2 倍。
  • IO 密集型任务:建议核心线程数设置为较大的值,最大线程数可以为核心线程数的 2 倍甚至更多。

合理配置线程池可以避免线程饥饿和死锁等问题,提升系统的吞吐量。

2. 使用 Java 原生线程池

Spring 提供线程池,但可以直接使用 Java 原生的线程池来实现异步。

示例代码:
package com.work.service;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;/*** 异步调用service* @author summer**/
@Service
@Slf4j
public class AsyncService{/*** 使用 Java 原生线程池来实现异步调用*/public void asyncThreadPool() {ThreadPoolExecutor pool=new ThreadPoolExecutor(5, 10, 2, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>(100),new ThreadPoolExecutor.CallerRunsPolicy());pool.execute(() -> {log.info("asyncThreadPool异步任务开始: " + Thread.currentThread().getName());try {// 模拟耗时操作(实际工作中,此处写业务逻辑处理)  Thread.sleep(30000);} catch (InterruptedException e) {e.printStackTrace();}log.info("asyncThreadPool异步任务完成");});}
}
调用:
package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;/*** 测试异步执行Controller* @author summer**/
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {@Autowiredprivate AsyncService asyncService;@GetMapping("/asyncThreadPool")public CommonResult<String> asyncThreadPool() {asyncService.asyncThreadPool();log.info("asyncThreadPool异步任务调用成功");return CommonResult.success("asyncThreadPool异步任务调用成功");}
}

异步方法休眠30秒,可以看到控制台打印的日志

3. 使用 Spring 的 TaskExecutor

TaskExecutor 是 Spring 提供的抽象接口,适合用来执行异步任务。

配置 TaskExecutor:
package com.work.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.task.TaskExecutor;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/*** 自定义异步线程执行线程池* @author summer**/
@Configuration
public class ExecutorConfig {@Bean(name = "taskExecutor")public TaskExecutor  taskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(5);executor.setMaxPoolSize(10);executor.setQueueCapacity(50);executor.setThreadNamePrefix("TaskExecutor-");executor.initialize();return executor;}
}
示例代码:
package com.work.service;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import lombok.extern.slf4j.Slf4j;
/*** 异步调用service* @author summer**/
@Service
@Slf4j
public class AsyncService{@Autowiredprivate TaskExecutor taskExecutor;/*** 使用 Spring 的 TaskExecutor 来实现异步调用*/public void asyncExecutor() {taskExecutor.execute(() -> {log.info("asyncExecutor异步任务开始:" + Thread.currentThread().getName());try {// 模拟耗时操作(实际工作中,此处写业务逻辑处理)  Thread.sleep(30000);} catch (InterruptedException e) {e.printStackTrace();}log.info("asyncExecutor异步任务完成");});}
}
调用:
package com.work.controller;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.work.common.result.CommonResult;
import com.work.service.AsyncService;
import lombok.extern.slf4j.Slf4j;/*** 测试异步执行Controller* @author summer**/
@RestController
@RequestMapping("/async")
@Slf4j
public class AsyncTestController {@Autowiredprivate AsyncService asyncService;@GetMapping("/asyncExecutor")public CommonResult<String> asyncExecutor() {asyncService.asyncExecutor();log.info("asyncExecutor异步任务调用成功");return CommonResult.success("asyncExecutor异步任务调用成功");}
}

异步方法休眠30秒,可以看到控制台打印的日志

三、什么时候使用异步请求

异步请求在以下情况下特别有用:

  • 长时间运行的任务:例如文件上传、复杂计算、大量数据处理等。
  • I/O操作:例如数据库查询、调用外部API、文件读写等。
  • 资源密集型任务:例如图像处理、视频编码等。
四、总结

方法

优点

缺点

@Async 注解

简单易用,与 Spring 集成良好

需要 Spring 容器管理的 Bean 才能生效

ExecutorService

更底层、更灵活

手动管理线程池

TaskExecutor

Spring 提供的抽象,方便扩展

配置稍显复杂

这些示例展示了如何在Spring Boot中实现异步请求和异步调用。Spring Boot提供了`@Async`注解和`Java原生线程池`、`TaskExecutor`来实现这一功能,提高了应用程序的并发处理能力,开发者可以根据不同的需求选择合适的异步处理方式。

合理配置线程池,以确保最佳性能和资源利用,正确处理异步任务中的异常,以及在合适的场景中应用异步处理技术,是开发高性能应用的关键。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/898555.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

使用vite新建vue3项目 以及elementui的使用 vite组件问题

项目创建 在创建项目之前我们应该在终端中输入 node -v 和 npm -v 只有它们都能正常查看版本号才说明我们之前是已经安装完成的。 接下来我们在合适的目录下输入npm create vitelatest 它会要求你输入项目的名称&#xff0c;这个名称和我们之前通过cil创建的命名规则一样。…

音频录制小妙招-自制工具-借助浏览器录一段单声道16000采样率wav格式音频

先看效果 1、打开页面 2、点击开始录音&#xff0c;弹出权限提示&#xff0c;点击“仅这次访问时允许” 3、录完后&#xff0c;点击停止 4、文件自动下载到默认目录 上代码 js 部分 document.addEventListener(DOMContentLoaded, () > {const startBtn document.getEleme…

数学建模 绘图 图表 可视化(3)

文章目录 前言二维散点图系列坐标图数据分布特征&#xff0c;Q-Q、P-P图分类图一般的曲线图峰峦图总结参考资料 前言 承接上期 数学建模 绘图 图表 可视化&#xff08;1&#xff09;的总体描述&#xff0c;这期我们继续跟随《Python 数据可视化之美 专业图表绘制指南》步伐来学…

【数据结构】栈(Stack)、队列(Queue)、双端队列(Deque) —— 有码有图有真相

目录 栈和队列 1. 栈&#xff08;Stack&#xff09; 1.1 概念 1.2 栈的使用&#xff08;原始方法&#xff09; 1.3 栈的模拟实现 【小结】 2. 栈的应用场景 1、改变元素的序列 2、将递归转化为循环 3、逆波兰表达式求值 4、括号匹配 5、出栈入栈次序匹配 6、最小栈…

【强化学习】Reward Model(奖励模型)详细介绍

&#x1f4e2;本篇文章是博主强化学习&#xff08;RL&#xff09;领域学习时&#xff0c;用于个人学习、研究或者欣赏使用&#xff0c;并基于博主对相关等领域的一些理解而记录的学习摘录和笔记&#xff0c;若有不当和侵权之处&#xff0c;指出后将会立即改正&#xff0c;还望谅…

国家雪亮工程政策护航,互联网监控管理平台铸就安全防线

在当今社会&#xff0c;公共安全是国家发展的重要基石&#xff0c;也是人民安居乐业的基本保障。为了打造更高水平的平安中国&#xff0c;国家推出了意义深远的雪亮工程&#xff0c;并出台了一系列相关政策&#xff0c;为公共安全事业保驾护航。而互联网监控管理平台作为雪亮工…

蓝桥杯 第十天 2019国赛第4题 矩阵计数

最后一个用例超时了&#xff0c;还是记录一下 import java.util.Scanner;public class Main {static int visited[][];static int count 0;static int n,m;public static void main(String[]args) {Scanner scan new Scanner(System.in);n scan.nextInt();//2m scan.nextIn…

coding ability 展开第五幕(二分查找算法)超详细!!!!

. . 文章目录 前言二分查找搜索插入的位置思路 x的平方根思路 山脉数组的峰顶索引思路 寻找旋转排序数组中的最小值思路 总结 前言 本专栏上篇博客已经把滑动指针收尾啦 现在还是想到核心——一段连续的区间&#xff0c;有时候加上哈希表用起来很爽 今天我们来学习新的算法知识…

基于springboot的母婴商城系统(018)

摘 要 现代经济快节奏发展以及不断完善升级的信息化技术&#xff0c;让传统数据信息的管理升级为软件存储&#xff0c;归纳&#xff0c;集中处理数据信息的管理方式。本母婴商城系统就是在这样的大环境下诞生&#xff0c;其可以帮助管理者在短时间内处理完毕庞大的数据信息&am…

shell 脚本搭建apache

#!/bin/bash # Set Apache version to install ## author: yuan# 检查外网连接 echo "检查外网连接..." ping www.baidu.com -c 3 > /dev/null 2>&1 if [ $? -eq 0 ]; thenecho "外网通讯良好&#xff01;" elseecho "网络连接失败&#x…

使用OBS进行webRTC推流参考

参考腾讯云官方文档&#xff1a; 云直播 OBS WebRTC 推流_腾讯云 说明非常详细&#xff0c;分为通过WHIP和OBS插件的形式进行推流。 注意&#xff1a;通过OBS插件的形式进行推流需要使用较低的版本&#xff0c;文档里有说明&#xff0c;需要仔细阅读。

Excel 小黑第18套

对应大猫18 .txt 文本文件&#xff0c;点数据 -现有链接 -浏览更多 &#xff08;文件类型&#xff1a;可以点开文件看是什么分隔的&#xff09; 双击修改工作表名称 为表格添加序号&#xff1a;在数字那修改格式为文本&#xff0c;输入第一个序号样式&#xff08;如001&#…

快速入手-基于Django的mysql配置(三)

Django开发操作数据库更简单&#xff0c;内部提供了ORM框架。比如mysql&#xff0c;旧版本用pymysql对比较多&#xff0c;新的版本采用mysqlclient。 1、安装mysql模块 pip install mysqlclient 2、Django的ORM主要做了两件事 &#xff08;1&#xff09;CRUD数据库中的表&am…

【总结篇】java多线程,新建线程有几种写法,以及每种写法的优劣势

java多线程 新建线程有几种写法,以及每种写法的优劣势 [1/5]java多线程 新建线程有几种写法–继承Thread类以及他的优劣势[2/5]java多线程-新建线程有几种写法–实现Runnable接口以及他的优劣势[3/5]java多线程 新建线程有几种写法–实现Callable接口结合FutureTask使用以及他的…

基于YOLOv8与ByteTrack的车辆行人多目标检测与追踪系统

作者主页&#xff1a;编程千纸鹤 作者简介&#xff1a;Java领域优质创作者、CSDN博客专家 、CSDN内容合伙人、掘金特邀作者、阿里云博客专家、51CTO特邀作者、多年架构师设计经验、多年校企合作经验&#xff0c;被多个学校常年聘为校外企业导师&#xff0c;指导学生毕业设计并参…

【芯片验证】面试题·对深度为60的数组进行复杂约束的技巧

朋友发给我的芯片验证笔试题,觉得很有意思,和大家分享一下。 面试题目 class A中一个长度为60的随机数组rand int arr[60],如何写约束使得: 1.每个元素的值都在(0,100]之间,且互不相等; 2.最少有三个元素满足勾股数要求,比如数组中包含3,4,5三个点; 请以解约束最快…

【论文阅读】Contrastive Clustering Learning for Multi-Behavior Recommendation

论文地址&#xff1a;Contrastive Clustering Learning for Multi-Behavior Recommendation | ACM Transactions on Information Systems 摘要 近年来&#xff0c;多行为推荐模型取得了显著成功。然而&#xff0c;许多模型未充分考虑不同行为之间的共性与差异性&#xff0c;以…

蓝桥杯2023年第十四届省赛真题-子矩阵

题目来自DOTCPP&#xff1a; 暴力思路&#xff08;两个测试点超时&#xff09;&#xff1a; 题目要求我们求出子矩阵的最大值和最小值的乘积&#xff0c;我们可以枚举矩阵中的所有点&#xff0c;以这个点为其子矩阵的左上顶点&#xff0c;然后判断一下能不能构成子矩阵。如果可…

centos 磁盘重新分割,将原来/home 下部分空间转移到 / 根目录下

上次重装系统时&#xff0c;不小心将一半磁盘放在了 /home 下面&#xff0c;运行一段时间后&#xff0c;发现/home 空间没有怎么用&#xff0c;反而是/ 目录报警说磁盘用完了&#xff0c;准备将 /home下的空间分一部分给主目录 / 先查看下 空间分布情况 df -lh 可以看到&…

【C#语言】C#同步与异步编程深度解析:让程序学会“一心多用“

文章目录 ⭐前言⭐一、同步编程&#xff1a;单线程的线性世界&#x1f31f;1、寻找合适的对象✨1) &#x1f31f;7、设计应支持变化 ⭐二、异步编程&#xff1a;多任务的协奏曲⭐三、async/await工作原理揭秘⭐四、最佳实践与性能陷阱⭐五、异步编程适用场景⭐六、性能对比实测…