1. Java虚拟线程
Java虚拟线程即协程,协程是用户态线程,用户态线程与内核态线程相比,可以减少上下文切换的消耗,并且更加轻量级。如下图:
协程有什么好处呢?我们可以和go类比一下,go在用户态实现了调度模块,每个go协程的Contex大小仅2k,远小于操作系统进程的Contex大小,在上下文切换的时候需要切换的内容小,调度不需要经过用户态内核态切换,速度远快操作系统进程,并且可以轻易的支持单机万以上规模的量级的go协程数量。
协程有很强的优势,新的语言go、rust大都从创立之初就支持协程,为何Java这么晚才支持协程。我们可以从两个对立的角度来看,一个角度是java落后其它语言,虚拟线程虽然改了个名字,实际上就是新新语言的协程;另外一个角度是Java语言与时俱进,终于迎头赶上支持协程。
2. Java虚拟线程编程
一个例子例下:
class CustomThread implements Runnable {
@Override
public void run() {
System.out.println("CustomThread run");
System.out.println(Thread.currentThread().isVirtual());
System.out.println(Thread.currentThread().getName());
}
}
//TIP To <b>Run</b> code, press <shortcut actionId="Run"/> or
// click the <icon src="AllIcons.Actions.Execute"/> icon in the gutter.
public class Main {
public static void main(String[] args) throws InterruptedException {
System.out.println("start main");
Thread thread = Thread.ofVirtual().name("test").unstarted(new CustomThread());
thread.start();
thread.join();
System.out.println("end main");
}
}
Java的虚拟线程在原有的Thread里进行扩展,增加了2个Builder的概念用于创建线程,一个PlatformThreadBuilder,一个VirtualThreadBuilder,PlatformThread实际上就是内核线程,VirtualThread就是协程。
再看一个例子:
try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
IntStream.range(0, 10_000).forEach(i -> executor.submit(() -> {
Thread.sleep(Duration.ofSeconds(1));
System.out.println("task: " + i);
return i;
}));
}
ForkJoinPool forkJoinPool = ForkJoinPool.commonPool();
forkJoinPool.submit(Thread.ofVirtual().start(new CustomThread()));
forkJoinPool.submit(new CustomThread());
try(var excutor = Executors.newSingleThreadExecutor()) {
excutor.submit(new CustomThread());
excutor.submit(Thread.ofVirtual().start(new CustomThread()));
}
Executors扩展了一个方法newVirtualThreadPerTaskExecutor()构造虚拟线程池,同时也支持submit任务的时候,接受平台线程或者虚拟线程。
3. 总结
接触新的概念要看底层本质,知道协程的本质,我们就知道这不是一个新事务掌握虚拟线程用法是很容易的。