Java19新特性协程

简介: 一直以来都在用Java8版本,最近突然看到了Java19的新特性记录一下。

Java相关文章


虚拟线程

不了解线程相关的东西的话可以参考之前的文章:


首先,所有语言的线程都仅仅是对操作系统线程的封装,所以线程的调度一般都是由操作系统负责,众所周知,操作系统分为了用户空间内核空间。日常编写的代码最终运行在用户空间中,所以在代码中使用线程都需要进行调用系统函数进行切换。


这个动作很消耗性能,所以一些新兴语言利用好协程的高性能特性成功的脱颖而出,协程是更加轻量级的线程,调度由用户自己控制。


眼看Golang依靠协程蒸蒸日上,Java也不敢示弱,在JDK19版本推出了虚拟线程的概念。 Java19 引入了虚拟线程(Virtual Thread)。在 Java19 中,之前我们常用的线程叫做平台线程(platform thread)。与系统内核线程仍然是一一对应的本质上是虚拟线程建立在线程之上,之前的线程和操作系统线是1比1,虚拟线程是建立在线程中,n:1,也就是n个虚拟线程绑定在一个线程中。


实战

//输出线程ID 包括虚拟线程和系统线程 Thread.getId() 从jdk19废弃Runnablerunnable= () ->System.out.println(Thread.currentThread().threadId());
//创建虚拟线程Threadthread=Thread.ofVirtual().name("testVT").unstarted(runnable);
testVT.start();
//创建虚平台线程ThreadtestPT=Thread.ofPlatform().name("testPT").unstarted(runnable);
testPT.start();


使用 Thread.startVirtualThread(Runnable) 快速创建虚拟线程并启动:

//输出线程ID 包括虚拟线程和系统线程
Runnable runnable = () -> System.out.println(Thread.currentThread().threadId());
Thread thread = Thread.startVirtualThread(runnable);



Thread.isVirtual() 判断线程是否为虚拟线程:

//输出线程ID 包括虚拟线程和系统线程
Runnable runnable = () -> System.out.println(Thread.currentThread().isVirtual());
Thread thread = Thread.startVirtualThread(runnable);


Thread.join 和 Thread.sleep 等待虚拟线程结束、使虚拟线程 sleep:

Runnable runnable = () -> System.out.println(Thread.sleep(10));
Thread thread = Thread.startVirtualThread(runnable);
//等待虚拟线程结束
thread.join();


Executors.newVirtualThreadPerTaskExecutor() 创建一个 ExecutorService,该 ExecutorService 为每个任务创建一个新的虚拟线程:

try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
  executor.submit(() -> System.out.println("hello"));
}



Java虚拟线程调度


旧版的线程调度依赖于操作系统管理生命周期。而对于虚拟线程,JDK内置了自己的调度器。JDK 的调度器没有直接将虚拟线程分配给系统线程,而是将虚拟线程分配给平台线程(这是前面提到的虚拟线程的 M:N 调度),平台线程由操作系统的线程调度系统调度。


JDK 的虚拟线程调度器是一个在 FIFO 模式下运行的类似 ForkJoinPool 的线程池。调度器的并行数量取决于调度器虚拟线程的平台线程数量。默认情况下是 CPU 可用核心数量,但可以使用系统属性 jdk.virtualThreadScheduler.parallelism 进行调整。注意,这里的 ForkJoinPool 与 ForkJoinPool.commonPool() 不同,ForkJoinPool.commonPool() 用于实现并行流,并在 LIFO 模式下运行。


为了防止线程饥饿问题,当一个线程的等待队列中没有更多的任务时,ForkJoinPool 还实现了另一种模式,称为任务窃取, 也就是说:饥饿线程可以从另一个线程的等待队列中窃取一些任务。




相关文章
|
3月前
|
Java API 数据处理
Java新特性:使用Stream API重构你的数据处理
Java新特性:使用Stream API重构你的数据处理
Java API 开发者
138 0
|
5月前
|
并行计算 Java API
Java List 集合结合 Java 17 新特性与现代开发实践的深度解析及实战指南 Java List 集合
本文深入解析Java 17中List集合的现代用法,结合函数式编程、Stream API、密封类、模式匹配等新特性,通过实操案例讲解数据处理、并行计算、响应式编程等场景下的高级应用,帮助开发者提升集合操作效率与代码质量。
270 1
|
5月前
|
安全 Java 微服务
Java 最新技术和框架实操:涵盖 JDK 21 新特性与 Spring Security 6.x 安全框架搭建
本文系统整理了Java最新技术与主流框架实操内容,涵盖Java 17+新特性(如模式匹配、文本块、记录类)、Spring Boot 3微服务开发、响应式编程(WebFlux)、容器化部署(Docker+K8s)、测试与CI/CD实践,附完整代码示例和学习资源推荐,助你构建现代Java全栈开发能力。
673 1
|
5月前
|
缓存 安全 Java
Java 并发新特性实战教程之核心特性详解与项目实战
本教程深入解析Java 8至Java 19并发编程新特性,涵盖CompletableFuture异步编程、StampedLock读写锁、Flow API响应式流、VarHandle内存访问及结构化并发等核心技术。结合电商订单处理、缓存系统、实时数据流、高性能计数器与用户资料聚合等实战案例,帮助开发者高效构建高并发、低延迟、易维护的Java应用。适合中高级Java开发者提升并发编程能力。
182 0
|
5月前
|
安全 Java API
Java 17 及以上版本核心特性在现代开发实践中的深度应用与高效实践方法 Java 开发实践
本项目以“学生成绩管理系统”为例,深入实践Java 17+核心特性与现代开发技术。采用Spring Boot 3.1、WebFlux、R2DBC等构建响应式应用,结合Record类、模式匹配、Stream优化等新特性提升代码质量。涵盖容器化部署(Docker)、自动化测试、性能优化及安全加固,全面展示Java最新技术在实际项目中的应用,助力开发者掌握现代化Java开发方法。
282 1
|
5月前
|
IDE Java API
Java 17 新特性与微服务开发的实操指南
本内容涵盖Java 11至Java 17最新特性实战,包括var关键字、字符串增强、模块化系统、Stream API、异步编程、密封类等,并提供图书管理系统实战项目,帮助开发者掌握现代Java开发技巧与工具。
308 0
|
5月前
|
Java 数据库连接 API
Java 8 + 特性及 Spring Boot 与 Hibernate 等最新技术的实操内容详解
本内容涵盖Java 8+核心语法、Spring Boot与Hibernate实操,按考试考点分类整理,含技术详解与代码示例,助力掌握最新Java技术与应用。
188 2