尝试将 Project Loom/虚拟线程与 OpenJDK 19-loom JAVA 一起使用时出现问题答案

【问题标题】：Problems trying to use Project Loom/Virtual Threads with OpenJDK 19-loom JAVA尝试将 Project Loom/虚拟线程与 OpenJDK 19-loom JAVA 一起使用时出现问题
【发布时间】：2022-01-31 21:18:50
【问题描述】：

我正在尝试在 Java 中测试虚拟线程参考 loom 项目，并且我正在使用以下 JDK 19-loom 版本：

  package com;

import java.util.concurrent.ThreadFactory;

    public class a {
    
    
        public static void main (String [] args) throws Exception{
            Runnable printThread = () -> System.out.println(Thread.currentThread());
    
            ThreadFactory virtualThreadFactory = Thread.builder().virtual().factory();
            ThreadFactory kernelThreadFactory = Thread.builder().factory();
    
            Thread virtualThread = virtualThreadFactory.newThread(printThread);
            Thread kernelThread = kernelThreadFactory.newThread(printThread);
    
            virtualThread.start();
            kernelThread.start();
    
        }
    }

我有以下 IntelliJ 配置：

但我遇到以下错误：

而且好像没有确定线程的建造者

我想知道我还需要什么？

【问题讨论】：

您是否尝试过在 IntelliJ 之外进行编译？如果 IntelliJ 使用语言级别 11 的 --release 标志，您将只能从 11 获取库符号。AFAIK 19 目前不适用于 IntelliJ（也许 EA 版本支持它......）。

标签： java multithreading performance process project-loom

【解决方案1】：

您使用的是过时的示例。

在 Loom 的当前状态下，您的示例看起来应该是这样的

public static void main(String[] args) throws InterruptedException {
    Runnable printThread = () -> System.out.println(Thread.currentThread());

    ThreadFactory virtualThreadFactory = Thread.ofVirtual().factory();
    ThreadFactory kernelThreadFactory = Thread.ofPlatform().factory();

    Thread virtualThread = virtualThreadFactory.newThread(printThread);
    Thread kernelThread = kernelThreadFactory.newThread(printThread);

    virtualThread.start();
    kernelThread.start();

    virtualThread.join();
    kernelThread.join();
}

但你也可以使用简化的

public static void main(String[] args) throws InterruptedException {
    Runnable printThread = () -> System.out.println(Thread.currentThread());

    Thread virtualThread = Thread.startVirtualThread(printThread);
    Thread kernelThread = Thread.ofPlatform().start(printThread);

    virtualThread.join();
    kernelThread.join();
}

请记住，这是正在进行的工作，文档可能很快就会过时。

【讨论】：