JDK19推出新特性虚拟线程是什么？-不念博客

JDK19推出了几个新的特性，其中最具有特点的有以下几个。

记录模式（预览版）：使用记录模式增强Java编程语言以解构记录值，可以嵌套记录模式和类型模式，实现强大的、声明性的和可组合的数据导航和处理形式。这是一个预览语言功能。
Linux/RISC-V移植：将JDK移植到Linux/RISC-V，目前仅支持RISC-V的RV64GV配置（包含向量指令的通用64位ISA）。将来可能会考虑支持其他RISC-V配置，例如通用32位配置(RV32G)。
外部函数和内存API（预览版）：引入一个API，Java程序可以通过该API与Java运行时之外的代码和数据进行互操作。这是一个预览版API。
虚拟线程（预览版）：将虚拟线程引入Java平台。虚拟线程是轻量级线程，可显著地减少编写、维护和观察高吞吐量并发应用程序的工作量。
结构化并发（培养阶段）：旨在通过结构化并发API简化多线程编程。这种并发性将在不同线程中运行的多个任务视为单个工作单元，以简化错误处理和取消，提高了可靠性和可观察性。这个特性来自Project Loom，它引入了一个新的轻量级并发模型。

我们看到其中有一个比较值得关注的那就是新增了虚拟线程。

到底什么是虚拟线程，和我们现在使用的线程有啥区别呢？

线程的实现方式

在操作系统中，线程是比进程更轻量级的调度执行单位，线程的引入可以把一个进程的资源分配和执行调度分开，各个线程既可以共享进程资源，又可以独立调度。

线程的实现方式主要有三种：分别是使用内核线程实现、使用用户线程实现以及使用用户线程加轻量级进程混合实现。

「使用内核线程实现」:内核线程（Kernel-Level Thread，KLT）直接由操作系统内核支持，由内核完成线程切换，内核通过操纵调度器对线程进行调度，并负责将线程的任务映射到各个处理器上，同时向应用程序提供API接口来管理线程。应用程序一般不直接使用内核线程，而是使用内核线程的一种高级接口——轻量级进程（Light Weight Process，LWP）。

应用程序一般不会直接去使用内核线程，而是去使用内核线程的一种高级接口——轻量级进程（Light Weight Process,LWP），轻量级进程就是我们通常意义上所讲的线程，由于每个轻量级进程都由一个内核线程支持，因此只有先支持内核线程，才能有轻量级进程。

有了内核线程的支持，每个轻量级进程都成为一个独立的调度单元，即使有一个轻量级进程在系统调用中阻塞了，也不会影响整个进程继续工作。

但是轻量级进程具有它的局限性：首先，由于是基于内核线程实现的，所以各种线程操作，如创建、析构及同步，都需要进行系统调用。而系统调用的代价相对较高，需要在用户态（User Mode）和内核态（Kernel Mode）中来回切换。其次，每个轻量级进程都需要有一个内核线程的支持，因此轻量级进程要消耗一定的内核资源（如内核线程的栈空间），因此一个系统支持轻量级进程的数量是有限的。

「使用用户线程实现」:在用户空间建立线程库，通过运行时系统完成线程的管理。这种实现方式下，一个进程和线程之间是一对多的关系。其优点是线程切换快，并且可以运行在任何操作系统之上，只需要实现线程库即可。

这种实现方式下，一个进程和线程之间的关系是一对多的。

这种线程实现方式的优点是线程切换快，并且可以运行在任何操作系统之上，只需要实现线程库就行了。但是缺点也比较明显，就是所有线程的操作都需要用户程序自己处理，并且因为大多数系统调用都是阻塞的，所以一旦一个进程阻塞了，那么进程中的所有线程也会被阻塞。还有就是多处理器系统中如何将线程映射到其他处理器上也是一个比较大的问题。

「使用用户线程加轻量级进程混合实现」:这种实现方式结合了上述两种方式的优点，既具有用户线程实现方式的线程切换快的优点，也具有内核线程实现方式的操作系统支持性好的优点。

「Java线程的实现方式」Java作为一门跨平台的编程语言，实际上他的线程的实现其实是依赖具体的操作系统的。而比较常用的windows和linux来说，都是采用内核线程的方式实现的。也就是说，当我们在JAVA代码中创建一个Thread的时候，其实是需要映射到操作系统的线程的具体实现的，因为常见的通过内核线程实现的方式在创建、调度时都需要进行内核参与，所以成本比较高，尽管JAVA中提供了线程池的方式来避免重复创建线程，但是依旧有很大的优化空间。而且这种实现方式意味着受机器资源的影响，平台线程数也是有限制的。

虚拟线程

JDK19引入的虚拟线程，虚拟线程是轻量级线程，主要用于实现高吞吐量的并发应用程序。

与传统的线程相比，虚拟线程具有更低的创建和销毁成本，可以更好地利用系统资源。

虚拟线程的主要优势:

高并发性：由于虚拟线程的创建和销毁成本低，因此可以在短时间内创建大量的虚拟线程，实现高并发处理。
资源利用率高：虚拟线程可以共享同一个进程的资源，如内存空间、文件描述符等，避免了资源的浪费，提高了系统的资源利用率。
易于管理和观察：虚拟线程是轻量级的，其创建、切换和管理都更加简单和快速。此外，由于虚拟线程共享同一个进程的资源，因此可以使用现有的工具和框架来观察和管理虚拟线程。

「虚拟线程与平台线程的区别」:

虚拟线程是守护线程，不能通过setDaemon(false)方法将其更改为非守护线程。当所有启动的非守护进程线程都终止时，JVM将终止，这意味着JVM不会等待虚拟线程完成后才退出。
虚拟线程的优先级始终为normal，并且不能通过setPriority()方法更改。在虚拟线程上调用此方法没有效果。
虚拟线程不支持stop()、suspend()或resume()等方法。在虚拟线程上调用这些方法将抛出UnsupportedOperationException异常。
虚拟线程并不与特定的操作系统线程绑定，其与操作系统线程的映射关系比例也不是1:1，而是m:n。虚拟线程通常是由Java运行时来调度的，而不是操作系统。当在虚拟线程中运行的代码调用阻塞的I/O操作时，Java运行时会将虚拟线程挂起，直到其可以恢复为止。

「如何使用虚拟线程」:通过Thread.startVirtualThread()可以运行一个虚拟线程：

Thread.startVirtualThread(() -> {
    System.out.println("虚拟线程执行中...");
});

通过Thread.Builder也可以创建虚拟线程，Thread类提供了ofPlatform()来创建一个平台线程、ofVirtual()来创建虚拟现场。

Thread.Builder platformBuilder = Thread.ofPlatform().name("平台线程");
Thread.Builder virtualBuilder = Thread.ofVirtual().name("虚拟线程");

Thread t1 = platformBuilder .start(() -> {...}); 
Thread t2 = virtualBuilder.start(() -> {...});

线程池也支持了虚拟线程，可以通过Executors.newVirtualThreadPerTaskExecutor()来创建虚拟线程:

try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
    IntStream.range(0, 10000).forEach(i -> {
        executor.submit(() -> {
            Thread.sleep(Duration.ofSeconds(1));
            return i;
        });
    });
}

其实并不建议虚拟线程和线程池一起使用，因为Java线程池的设计是为了避免创建新的操作系统线程的开销，但是创建虚拟线程的开销并不大，所以其实没必要放到线程池中。

「性能差异」从Runnable创建10000个线程，并使用虚拟线程和平台线程执行它们，以比较两者的性能。

final AtomicInteger atomicInteger = new AtomicInteger();

Runnable runnable = () -> {
  try {
    Thread.sleep(Duration.ofSeconds(1));
  } catch(Exception e) {
      System.out.println(e);
  }
  System.out.println("Work Done - " + atomicInteger.incrementAndGet());
};

传统线程实现:

Instant start = Instant.now();

try (var executor = Executors.newFixedThreadPool(100)) {
  for(int i = 0; i < 10_000; i++) {
    executor.submit(runnable);
  }
}

Instant finish = Instant.now();
long timeElapsed = Duration.between(start, finish).toMillis();  
System.out.println("总耗时 : " + timeElapsed);

虚拟线程实现:

Instant start = Instant.now();

try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
  for(int i = 0; i < 10_000; i++) {
    executor.submit(runnable);
  }
}

Instant finish = Instant.now();
long timeElapsed = Duration.between(start, finish).toMillis();  
System.out.println("总耗时 : " + timeElapsed);

最终结果: