当前位置:首页 > 科技  > 软件

SpringBoot3使用虚拟线程一定要小心了

来源: 责编: 时间:2024-05-11 09:21:24 243观看
导读环境:SpringBoot3.2.5 + JDK211.简介SpringBoot从3.2.0-M1版本开始支持虚拟线程。虚拟线程是JDK 21版本正式发布的一个新特性,它与平台线程的主要区别在于虚拟线程在运行周期内不依赖操作系统线程,而是与硬件脱钩,因此被

环境:SpringBoot3.2.5 + JDK213GZ28资讯网——每日最新资讯28at.com

1.简介

SpringBoot从3.2.0-M1版本开始支持虚拟线程。虚拟线程是JDK 21版本正式发布的一个新特性,它与平台线程的主要区别在于虚拟线程在运行周期内不依赖操作系统线程,而是与硬件脱钩,因此被称为“虚拟”。这种解耦是由JVM提供的抽象层赋予的,使得虚拟线程的运行成本远低于平台线程,并且可以消耗更少的内存。因此,从SpringBoot 3.2.0-M1开始,通过使用虚拟线程,提升系统的整体性能。3GZ28资讯网——每日最新资讯28at.com

虚拟线程在项目中应用时你稍不注意就可能出现问题。本篇文章将要讲述的是在非Web应用的情况下使用虚拟线程出现的问题(并非BUG)。3GZ28资讯网——每日最新资讯28at.com

2. 实战案例

注意:本案例是非Web应用。只要你不要引入spring-boot-starter-web模块或者下面配置后都将以非web模式下运行。3GZ28资讯网——每日最新资讯28at.com

public static void main(String[] args) {  new SpringApplicationBuilder()    .sources(SpringbootNonWebApplication.class)    // 即便引入了web模块,但这里设置为非web应用    .web(WebApplicationType.NONE)    .run(args) ;}

非web应用,启动容器后并不会启动嵌入式的web server,如果你当前应用中并没有其它线程执行(非守护线程),那么程序将自动停止(启动即停止)。3GZ28资讯网——每日最新资讯28at.com

图片图片3GZ28资讯网——每日最新资讯28at.com

启动完后自动停止。3GZ28资讯网——每日最新资讯28at.com

2.1 启动定时任务

在一个非web环境下启动定时任务:3GZ28资讯网——每日最新资讯28at.com

@Componentpublic class TaskComponent {  @Scheduled(fixedRate = 3000)  public void task1() throws Exception {    System.out.printf("当前执行线程: %s%n", Thread.currentThread()) ;    // TODO 执行任务    TimeUnit.SECONDS.sleep(1) ;  }}

上面定义了每隔3s执行的定时任务(记得通过@EnableScheduling注解开启任务调用功能)。3GZ28资讯网——每日最新资讯28at.com

启动服务3GZ28资讯网——每日最新资讯28at.com

图片图片3GZ28资讯网——每日最新资讯28at.com

程序规律的执行,每隔3s输出信息。3GZ28资讯网——每日最新资讯28at.com

2.2 虚拟线程执行任务

接下来开启虚拟线程。3GZ28资讯网——每日最新资讯28at.com

如果运行的是 Java 21 或更高版本,可以通过配置如下属性来启用虚拟线程。3GZ28资讯网——每日最新资讯28at.com

spring:  threads:    virtual:      enabled: true

再次运行程序3GZ28资讯网——每日最新资讯28at.com

图片图片3GZ28资讯网——每日最新资讯28at.com

根据打印信息,执行线程确实是通过虚拟线程执行,但是仅仅启动时输出了一条信息,程序就终止了,这肯定不是我们想要的。什么原因呢?3GZ28资讯网——每日最新资讯28at.com

2.3 守护线程

这是一段非常简单的代码了3GZ28资讯网——每日最新资讯28at.com

Thread t = new Thread(() -> {  try {    System.out.println("start..." + System.currentTimeMillis()) ;    TimeUnit.SECONDS.sleep(5) ;  } catch (Exception e) {    e.printStackTrace() ;  }  System.out.println(" over..." + System.currentTimeMillis()) ;}) ;t.start() ;

输出结果:3GZ28资讯网——每日最新资讯28at.com

start...1613150235234 over...1613150240238

程序等待3s后终止。接下来将上面Thread线程做如下配置:3GZ28资讯网——每日最新资讯28at.com

// 设置为守护线程t.setDaemon(true) ;

再次执行,这次执行控制台不会有任何的输出程序就终止了。3GZ28资讯网——每日最新资讯28at.com

在Java中当所有非守护线程都执行完以后,守护线程会自动终止;守护线程一般用于执行后台任务,资源清理等。3GZ28资讯网——每日最新资讯28at.com

接下来通过虚拟线程执行上面的代码:3GZ28资讯网——每日最新资讯28at.com

OfVirtual virtual = Thread.ofVirtual().name("Pack-") ;Thread t = virtual.start(() -> {  try {    System.out.println("start..." + System.currentTimeMillis()) ;    TimeUnit.SECONDS.sleep(5) ;  } catch (Exception e) {    e.printStackTrace() ;  }  System.out.println("over..." + System.currentTimeMillis()) ;}) ;TimeUnit.SECONDS.sleep(1) ;

等待1s后程序终止,只输出如下结果:3GZ28资讯网——每日最新资讯28at.com

start...1613840844449

虚拟线程难道也是守护线程?3GZ28资讯网——每日最新资讯28at.com

通过如下代码查看上面的虚拟线程是否是守护线程:3GZ28资讯网——每日最新资讯28at.com

System.out.println(t.isDaemon()) ;

输出结果:3GZ28资讯网——每日最新资讯28at.com

true

既然是守护线程,那么程序自动停止也就不意外了。下面是来自官方对虚拟线程与平台线程的区别:3GZ28资讯网——每日最新资讯28at.com

  • 虚拟线程始终是守护线程。Thread.setDaemon(boolean) 方法无法将虚拟线程更改为非守护线程。
  • 虚拟线程的固定优先级为 Thread.NORM_PRIORITY。Thread.setPriority(int) 方法对虚拟线程不起作用。这一限制可能会在未来的版本中重新考虑。
  • 虚拟线程不是线程组的活动成员。在虚拟线程上调用 Thread.getThreadGroup() 时,会返回一个名称为 "VirtualThreads "的占位线程组。Thread.Builder API 没有定义设置虚拟线程线程组的方法。

2.4 KeepAlive虚拟线程

既然虚拟线程是守护线程,那么要如何解决上面的问题呢?在SpringBoot3.2.0-RC1版本开始为SpringApplication添加"keep-alive"属性,专门解决虚拟线程问题。3GZ28资讯网——每日最新资讯28at.com

可以通过如下配置开启keepAlive。3GZ28资讯网——每日最新资讯28at.com

spring:  main:    keep-alive: true

通过上面的配置后,再次运行上面的程序3GZ28资讯网——每日最新资讯28at.com

图片图片3GZ28资讯网——每日最新资讯28at.com

这时候程序不会退出了一直运行。✔3GZ28资讯网——每日最新资讯28at.com

2.5 实现原理

当开启上面的spring.main.keep-alive=true后,springboot在启动时会注册一个监听器。3GZ28资讯网——每日最新资讯28at.com

public class SpringApplication {  public ConfigurableApplicationContext run(String... args) {    // ...    prepareContext(bootstrapContext, context, environment, listeners, applicationArguments, printedBanner);    // ...  }  private void prepareContext(...) {    // ...    // SpringBoot在启动时准备Environment时会自动将spring.main下的    // 属性配置绑定到当前的SpringApplication对象中(属性)。    if (this.keepAlive) {      // 添加事件监听      context.addApplicationListener(new KeepAlive());    }    // ...  }}

事件监听程序KeepAlive。3GZ28资讯网——每日最新资讯28at.com

private static final class KeepAlive implements ApplicationListener<ApplicationContextEvent> {  public void onApplicationEvent(ApplicationContextEvent event) {    if (event instanceof ContextRefreshedEvent) {      // Spring上下文刷新完成      startKeepAliveThread();    }    // Spring容器在关闭时    else if (event instanceof ContextClosedEvent) {      stopKeepAliveThread();    }  }  private void startKeepAliveThread() {    // 启动异步线程,一直休眠(保证一直运行着,这样程序就不会终止了)    Thread thread = new Thread(() -> {      while (true) {        try {          Thread.sleep(Long.MAX_VALUE);        }      }    });    if (this.thread.compareAndSet(null, thread)) {      // 非守护线程      thread.setDaemon(false);      thread.setName("keep-alive");      thread.start();    }  }  private void stopKeepAliveThread() {    Thread thread = this.thread.getAndSet(null);    if (thread == null) {      return;    }    // 终止线程    thread.interrupt();  }}

SpringBoot实现逻辑还是非常简单的。3GZ28资讯网——每日最新资讯28at.com

本文链接://www.dmpip.com//www.dmpip.com/showinfo-26-87991-0.htmlSpringBoot3使用虚拟线程一定要小心了

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com

上一篇: 一图看懂 React 源码中的同步更新逻辑

下一篇: Go语言整型(整数类型)的详解

标签:
  • 热门焦点
Top
Baidu
map