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 还实现了另一种模式,称为任务窃取, 也就是说:饥饿线程可以从另一个线程的等待队列中窃取一些任务。




相关文章
|
1天前
|
Java API 数据处理
Java 8的新特性详解
Java 8的新特性详解
|
1天前
|
Java API 开发者
Java版本对比:特性、升级改动与优势分析
Java版本对比:特性、升级改动与优势分析
9 0
|
4天前
|
Java API 开发者
高效利用Java中的函数式编程特性
高效利用Java中的函数式编程特性
|
4天前
|
Java API 开发者
Java 8的新特性简单分享(后续有系列篇~敬请期待)
Java 8的新特性简单分享(后续有系列篇~敬请期待)
8 1
|
5天前
|
JavaScript 前端开发 Java
Java11 新特性深度解析
Java11 新特性深度解析
|
5天前
|
SQL 运维 Java
深度解析Java 9核心新特性
深度解析Java 9核心新特性
|
5天前
|
Java 编译器 API
技术经验分享:JAVA8十大新特性详解
技术经验分享:JAVA8十大新特性详解
|
6天前
|
安全 Java C++
深入探究Java中的TransferQueue:机制、特性与应用场景
深入探究Java中的TransferQueue:机制、特性与应用场景
|
6天前
|
安全 Java API
JDK 11 vs JDK 8:探索Java的新特性和改进
JDK 11 vs JDK 8:探索Java的新特性和改进
|
6天前
|
并行计算 JavaScript 前端开发
Java 8新特性全面解读
Java 8新特性全面解读