我觉得这个很简单
首先确保你idea支持jdk21.
然后把idea编译成的目标字节码设置为21版本的
然后编写代码。
创建虚拟线程的方式有:
Runnable runnable = () -> {System.out.println("Hello, world!");
};// 创建虚拟线程
Thread virtualThread = Thread.startVirtualThread(runnable);// 开始虚拟线程
Thread.ofVirtual().name("my-virtual001").start(runnable);
Runnable runnable = () -> {System.out.println("Hello!");
};try (ExecutorService executorService = Executors.newVirtualThreadPerTaskExecutor()) {for (int i = 0; i < 100; i++) {executorService.submit(runnable);}
}
Runnable runnable = () -> {System.out.println("Hello!");
};ThreadFactory virtualThreadFactory = Thread.ofVirtual().name("qian", 0).factory();Thread factoryThread = virtualThreadFactory.newThread(runnable);
factoryThread.start();
然后编写连接数据库的代码:(记住引入java连接mysql的驱动)
package org.tianfan.mysqlTest;import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
import java.util.concurrent.ThreadFactory;public class Test001 {static String name = "root";static String password = "123456";static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";static final String DB_URL = "jdbc:mysql://localhost:3306/itheima?useSSL=false&allowPublicKeyRetrieval=true&serverTimezone=UTC";public static void main(String[] args) throws InterruptedException {Runnable runnable = () -> {Connection conn = null;Statement stmt = null;try {// 注册 JDBC 驱动Class.forName(JDBC_DRIVER);// 打开链接System.out.println("连接数据库...");conn = DriverManager.getConnection(DB_URL, name, password);System.out.println("连接成功...");}catch (Exception e){e.printStackTrace();}};// 使用静态构建器方法Thread virtualThread = Thread.startVirtualThread(runnable);Thread.sleep(1000);}}
结果展示图: