Java Academy · 课时

创建虚拟线程

Q: 「创建虚拟线程」这节课中我会学到什么？

Thread.ofVirtual 与执行器 你通过在浏览器中直接运行的动手代码来练习 Java Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

Thread.ofVirtual 与执行器

创建虚拟线程 是 CoddyKit 上的免费 Java Academy 课时。这是第 2 节课，共 4 节。你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。这是 Java Academy 学习路径的一部分，你的进度在网页和 CoddyKit 应用中同步。 Java Academy 课程共包含 4 节课。

创建虚拟线程的方式

Java 提供了多种创建虚拟线程的入口。最重要的两个是 Thread.ofVirtual() 构建器和 Executors.newVirtualThreadPerTaskExecutor() 工厂。

本课将逐一介绍它们。

构建器：start

Thread.ofVirtual() 返回一个构建器。调用 .start(runnable) 会创建线程并立即启动它。

public class Main {
    public static void main(String[] args) throws InterruptedException {
        Thread t = Thread.ofVirtual().start(() ->
            System.out.println("Started directly"));
        t.join();
    }
}

构建器：unstarted

如果您希望先配置线程、稍后再启动，请使用 .unstarted(runnable)。

public class Main {
    public static void main(String[] args) throws InterruptedException {
        Thread t = Thread.ofVirtual().unstarted(() ->
            System.out.println("Started later"));
        System.out.println("Before start, alive? " + t.isAlive());
        t.start();
        t.join();
    }
}

可复用的工厂

构建器可以通过 .factory() 生成一个 ThreadFactory。每次调用 newThread 都会得到一个全新的虚拟线程。

import java.util.concurrent.ThreadFactory;

public class Main {
    public static void main(String[] args) throws InterruptedException {
        ThreadFactory factory = Thread.ofVirtual().name("job-", 0).factory();
        Thread a = factory.newThread(() ->
            System.out.println(Thread.currentThread().getName()));
        Thread b = factory.newThread(() ->
            System.out.println(Thread.currentThread().getName()));
        a.start(); b.start();
        a.join(); b.join();
    }
}

便捷方法

Thread.startVirtualThread(runnable) 是在一次调用中创建并启动未命名虚拟线程的简写。

public class Main {
    public static void main(String[] args) throws InterruptedException {
        Thread t = Thread.startVirtualThread(() ->
            System.out.println("One-liner virtual thread"));
        t.join();
    }
}

执行器方式

对于面向任务的代码，请优先使用 Executors.newVirtualThreadPerTaskExecutor()。它会为每个提交的任务创建一个新的虚拟线程。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Main {
    public static void main(String[] args) {
        try (ExecutorService exec = Executors.newVirtualThreadPerTaskExecutor()) {
            exec.submit(() -> System.out.println("task one"));
            exec.submit(() -> System.out.println("task two"));
        }
        System.out.println("All tasks submitted and completed");
    }
}

为何使用资源自动关闭语句

从 Java 19 开始，ExecutorService 实现了 AutoCloseable。在资源自动关闭语句块中关闭它，会等待所有已提交的任务完成。

这样无需手动调用 shutdown 和 awaitTermination，就能实现清晰、结构化的关闭。

提交大量任务

按任务创建线程的执行器可以轻松处理海量任务。每个任务都会获得自己的虚拟线程。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;

public class Main {
    public static void main(String[] args) {
        AtomicInteger sum = new AtomicInteger();
        try (ExecutorService exec = Executors.newVirtualThreadPerTaskExecutor()) {
            for (int i = 1; i <= 1000; i++) {
                final int n = i;
                exec.submit(() -> sum.addAndGet(n));
            }
        }
        System.out.println("Sum 1..1000 = " + sum.get());
    }
}

使用异步结果收集结果

submit 会返回一个 Future，因此您可以像使用任何执行器一样收集返回值。

import java.util.concurrent.*;

public class Main {
    public static void main(String[] args) throws Exception {
        try (ExecutorService exec = Executors.newVirtualThreadPerTaskExecutor()) {
            Future<Integer> f = exec.submit(() -> 6 * 7);
            System.out.println("Result: " + f.get());
        }
    }
}

构建器与执行器

请根据使用意图进行选择：

构建器 / startVirtualThread：用于一次性线程或自定义名称
newVirtualThreadPerTaskExecutor：用于提交任务集合并收集结果

两者都会为每个工作单元创建一个虚拟线程，这正是您所需要的。

不要缓存虚拟线程执行器

不要把单个虚拟线程执行器当作固定的工作线程池来复用。执行器本身可以复用，但请记住，每个任务都会生成一个全新的线程。

重点是：线程不会被放入线程池，只有任务提交很方便。

快速检验

请选择最适合运行大批任务的方式，让每个任务都在自己的虚拟线程上运行。

回顾

现在您已经知道如何创建虚拟线程：

Thread.ofVirtual().start(...) 和 .unstarted(...)
Thread.startVirtualThread(...) 单行写法
.factory() 用于获得可复用的 ThreadFactory
结合资源自动关闭语句使用 Executors.newVirtualThreadPerTaskExecutor()

下一步：在平台线程和虚拟线程之间进行选择。

常见问题解答

「创建虚拟线程」课时是免费的吗？

是的 — 「创建虚拟线程」的完整文本可在网页上免费阅读。要进行交互式练习（内置代码编辑器和全天候 AI 导师）并解锁 Java Academy 课程的其余内容，请升级到 CoddyKit PRO。 Java Academy 课程共包含 4 节课。

「创建虚拟线程」这节课中我会学到什么？

Thread.ofVirtual 与执行器你通过在浏览器中直接运行的动手代码来练习 Java Academy，全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 Java Academy 需要有经验吗？

无需任何先前经验。CoddyKit 上的 Java Academy 课程适合初学者到高级学习者，你可以从这里开始或从头开始，按照自己的节奏学习。这是第 2 节课，共 4 节。

「创建虚拟线程」课时需要多长时间？

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动，所以你能稳步进步，并在网页和应用中从离开的地方继续。

我能在这节 Java Academy 课中编写并运行代码吗？

能。每节 Java Academy 课都包含内置代码编辑器，你可以在浏览器中直接编写并运行真实代码，并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

← 返回 Java Academy