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

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

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

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

1.简介

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

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

2. 实战案例

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

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

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

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

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

2.1 启动定时任务

在一个非web环境下启动定时任务:MGf28资讯网——每日最新资讯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注解开启任务调用功能)。MGf28资讯网——每日最新资讯28at.com

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

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

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

2.2 虚拟线程执行任务

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

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

spring:  threads:    virtual:      enabled: true

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

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

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

2.3 守护线程

这是一段非常简单的代码了MGf28资讯网——每日最新资讯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() ;

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

start...1613150235234 over...1613150240238

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

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

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

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

接下来通过虚拟线程执行上面的代码:MGf28资讯网——每日最新资讯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后程序终止,只输出如下结果:MGf28资讯网——每日最新资讯28at.com

start...1613840844449

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

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

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

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

true

既然是守护线程,那么程序自动停止也就不意外了。下面是来自官方对虚拟线程与平台线程的区别:MGf28资讯网——每日最新资讯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"属性,专门解决虚拟线程问题。MGf28资讯网——每日最新资讯28at.com

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

spring:  main:    keep-alive: true

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

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

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

2.5 实现原理

当开启上面的spring.main.keep-alive=true后,springboot在启动时会注册一个监听器。MGf28资讯网——每日最新资讯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。MGf28资讯网——每日最新资讯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实现逻辑还是非常简单的。MGf28资讯网——每日最新资讯28at.com

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

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

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

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

标签:
  • 热门焦点
  • Raft算法:保障分布式系统共识的稳健之道

    1. 什么是Raft算法?Raft 是英文”Reliable、Replicated、Redundant、And Fault-Tolerant”(“可靠、可复制、可冗余、可容错”)的首字母缩写。Raft算法是一种用于在分布式系统
  • 服务存储设计模式:Cache-Aside模式

    Cache-Aside模式一种常用的缓存方式,通常是把数据从主存储加载到KV缓存中,加速后续的访问。在存在重复度的场景,Cache-Aside可以提升服务性能,降低底层存储的压力,缺点是缓存和底
  • Java NIO内存映射文件:提高文件读写效率的优秀实践!

    Java的NIO库提供了内存映射文件的支持,它可以将文件映射到内存中,从而可以更快地读取和写入文件数据。本文将对Java内存映射文件进行详细的介绍和演示。内存映射文件概述内存
  • 梁柱接棒两年,腾讯音乐闯出新路子

    文丨田静 出品丨牛刀财经(niudaocaijing)7月5日,企鹅FM发布官方公告称由于业务调整,将于9月6日正式停止运营,这意味着腾讯音乐长音频业务走向消亡。腾讯在长音频领域还在摸索。为
  • 猿辅导与新东方的两种“归途”

    作者|卓心月 出品|零态LT(ID:LingTai_LT)如何成为一家伟大企业?答案一定是对&ldquo;势&rdquo;的把握,这其中最关键的当属对企业战略的制定,且能够站在未来看现在,即使这其中的
  • 阿里大调整

    来源:产品刘有媒体报道称,近期淘宝天猫集团启动了近年来最大的人力制度改革,涉及员工绩效、层级体系等多个核心事项,目前已形成一个初步的&ldquo;征求意见版&rdquo;:1、取消P序列
  • iQOO Neo8 Pro真机谍照曝光:天玑9200+和V1+旗舰双芯加持

    去年10月,iQOO推出了iQOO Neo7系列机型,不仅搭载了天玑9000+,而且是同价位唯一一款天玑9000+直屏旗舰,一经上市便受到了用户的广泛关注。在时隔半年后,
  • iQOO Neo8系列或定档5月23日:首发天玑9200+ 安卓跑分王者

    去年10月,iQOO推出了iQOO Neo7系列机型,不仅搭载了天玑9000+,而且是同价位唯一一款天玑9000+直屏旗舰,一经上市便受到了用户的广泛关注。在时隔半年后,
  • 联想YOGA 16s 2022笔记本将要推出,屏幕支持触控功能

    联想此前宣布,将于11月2日19:30召开联想秋季轻薄新品发布会,推出联想 YOGA 16s 2022 笔记本等新品。官方称,YOGA 16s 2022 笔记本将搭载 16 英寸屏幕,并且是一
Top