当前位置: 首页 > news >正文

罗永浩做的网站优化大师手机版

罗永浩做的网站,优化大师手机版,武汉影楼网站建设,网上做公司网站怎么做spring boot 开启异步调用 1、启动类上添加EnableAsync注解,表示启动异步 2、在具体实现异步的方法上添加Async注解 package com.example.demo;import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootAppli…

spring boot 开启异步调用

1、启动类上添加@EnableAsync注解,表示启动异步

2、在具体实现异步的方法上添加@Async注解

package com.example.demo;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;@SpringBootApplication
@EnableAsync
public class DemoApplication {public static void main(String[] args) {SpringApplication.run(DemoApplication.class, args);}}
package com.example.demo;import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;/*** @Description: TODO* @author: sl* @date: 2024年05月30日 21:55*/
@Component
public class DemoController {/***  Async相当于是方法级别的线程,本身没有自定义线程池更加灵活*  相当于是每进来一个请求就开启一个线程,超过核心线程数小于最大线程数放入队列,*  队列满了,继续创建线程直至达到最大线程数* @throws InterruptedException*/@Asyncpublic void testSync() throws InterruptedException {Thread.sleep(2000);System.out.println("异步执行成功");}
}

测试执行 

package com.example.demo;import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;@SpringBootTest
class DemoApplicationTests {@Autowiredprivate DemoController demoController;@Testvoid contextLoads() throws InterruptedException {demoController.testSync();System.out.println("主线程执行");Thread.sleep(4000);}}

执行结果 

执行原理

SpringBoot会默创建了一个线程池,使用这里面的线程来执行异步调用,在项目中使用

手动创建线程池异步调用 

常用线程池创建以及弊端

Executors 是一个 Java 中的工具类。提供四种线程池创建方式,工厂方法来创建不同类型的线程池。Executors 的创建线程池的方法,创建出来的线程池都实现了ExecutorService 接口,

1.newFiexedThreadPool(int Threads):创建固定数目线程的线程池。
2.newCachedThreadPool():创建一个可缓存的线程池,调用 execute将重用以前构造的线程(如果线程可用)。如果没有可用的线程,则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。
3.newSingleThreadExecutor() 创建一个单线程化的 Executor。
4.newScheduledThreadPool(int corePoolSize) 创建一个支持定时及周期性的任务执行的线程池,多数情况下可用来替代 Timer 类

不建议大家使用Executors这个类来创建线程池呢,阿里开发手册这样定义:
强制】线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式

Executors 返回的线程池对象的弊端如下:

1) FixedThreadPool 和 SingleThreadPool:

允许的请求队列长度为 Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM

2) CachedThreadPool 和 ScheduledThreadPool:

允许的创建线程数量为 Integer.MAX_VALUE, 可能会创建大量的线程,从而导致 OOM

使用常见的三种线程池创建方式,单一、可变、定长都有一定问题,原因是 FixedThreadPool 和 SingleThreadExecutor 底层都是用LinkedBlockingQueue 实现的,这个队列最大长度为 Integer.MAX_VALUE,容易导致 OOM
所以实际生产一般自己通过 ThreadPoolExecutor 的 7 个参数,自定义线程池

spring boot创建线程池 

springboot创建线程池,Spring提供的对ThreadPoolExecutor封装的线程池ThreadPoolTaskExecutor,直接使用注解启用。
Async相当于是方法级别的线程,本身没有自定义线程池更加灵活

package com.example.demo.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;import java.util.concurrent.ThreadPoolExecutor;/*** @Description: TODO* @author: sl* @date: 2024年05月30日 22:37*/
@Configuration
public class MyPoolConfig {@Beanpublic TaskExecutor taskExecutor(){ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();//设置核心线程数executor.setCorePoolSize(10);//设置最大线程数executor.setMaxPoolSize(15);//设置队列容量executor.setQueueCapacity(20);//设置线程活跃时间(秒)executor.setKeepAliveSeconds(60);//设置默认线程名称executor.setThreadNamePrefix("1111-");//设置拒绝策略executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());//等待所有任务结束后再关闭线程池executor.setWaitForTasksToCompleteOnShutdown(true);return executor;}}

在Async中指定线程池

package com.example.demo;import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;/*** @Description: TODO* @author: sl* @date: 2024年05月30日 21:55*/
@Component
public class DemoController {/***  Async相当于是方法级别的线程,本身没有自定义线程池更加灵活*  相当于是每进来一个请求就开启一个线程,超过核心线程数小于最大线程数放入队列,*  队列满了,继续创建线程直至达到最大线程数* @throws InterruptedException*/@Async("taskExecutor")public void testSync() throws InterruptedException {System.out.println(Thread.currentThread().getName());Thread.sleep(2000);System.out.println("异步执行成功");}
}

执行结果:

http://www.hrbkazy.com/news/13087.html

相关文章:

  • 厦门网站建设屈兴东营销方案范文100例
  • 在线音乐网站怎么做google官网登录入口
  • 网站即时在线客服关键词制作软件
  • 网站建设做什么好上海网络推广招聘
  • 叫别人做网站需要注意什么问题正规网络推广服务
  • 企业建网站服务重庆网站外包
  • 贵阳做网站建设最好的是哪家网站搜索引擎优化工具
  • 做妇产科网站国外b站浏览器
  • 荆州哪里做网站精准营销的成功案例
  • wordpress 分页url百度seo详解
  • 网站建设先进个人事迹seo顾问服务
  • 网站建设上的新闻品牌宣传策略有哪些
  • 合肥生态建设职业培训学校网站网络营销岗位
  • 开发网站的成本天津seo建站
  • 济南市城乡建设委员会的网站windows优化大师怎么使用
  • 做网站推广销售产品seo排名怎么做
  • 网站模板 php代运营靠谱吗
  • 前端开发工具下载在线排名优化工具
  • 织梦做旅游网站石家庄网站建设培训
  • 杭州高端网站制作爱网站
  • 网站建设工作总结培训微信营销平台哪个好
  • 徐州好点的做网站的公司有哪些长春网站优化平台
  • 工程建设标准网站百度教育官网
  • 北京网站开发哪家公司好厦门seo专业培训学校
  • 网站词库怎么做外贸网
  • 电脑公司网站设计如何做网站营销推广
  • 湘潭学校网站建设 磐石网络专注企业排名优化公司
  • 汽车装饰网站源码拉新推广渠道
  • 北京网站seo优化排名深圳搜索引擎优化收费
  • tp 网站建设源码星链友店