0

0

Java虚拟线程并发编程示例_Java虚拟线程如何实现高并发IO任务

冷漠man

冷漠man

发布时间:2025-12-22 11:04:28

|

446人浏览过

|

来源于php中文网

原创

虚拟线程是jvm对平台线程的轻量级抽象,使同步io代码可轻松支持数万并发;只需用thread.ofvirtual()或newvirtualthreadpertaskexecutor(),无需改写逻辑、线程池或响应式编程。

java虚拟线程并发编程示例_java虚拟线程如何实现高并发io任务 - php中文网

虚拟线程让高并发IO任务变简单

Java 21 引入的虚拟线程(Virtual Thread)不是“新线程模型”,而是 JVM 层面对传统平台线程的轻量级抽象。它不改变并发逻辑,但彻底降低了编写高吞吐 IO 密集型程序的门槛——你不再需要手动管理线程池、避免阻塞、或切换到响应式编程,用最直觉的同步写法就能跑出数万并发。

一个真实可用的HTTP并发调用示例

假设你要同时请求1000个外部API(如天气服务),用传统线程会快速耗尽系统资源;用虚拟线程,只需把 new Thread() 换成 Thread.ofVirtual(),其余代码几乎不变:

try (var executor = Executors.newVirtualThreadPerTaskExecutor()) {
    List<Future<String>> futures = IntStream.range(0, 1000)
        .mapToObj(i -> executor.submit(() -> {
            // 同步阻塞调用 —— 这里可以是 HttpURLConnection、OkHttp、JDBC 查询等
            return fetchWeather("beijing"); // 内部含 sleep(500) 或网络等待
        }))
        .toList();

    futures.forEach(future -> {
        try {
            System.out.println("Result: " + future.get()); // 自动解阻塞,不卡住调度器
        } catch (Exception e) {
            e.printStackTrace();
        }
    });
}

关键点:

  • 使用 Executors.newVirtualThreadPerTaskExecutor() 获取专为虚拟线程优化的执行器,它内部自动复用少量平台线程来调度大量虚拟线程
  • 每个任务用普通同步IO(比如 HttpURLConnection.getInputStream().readAllBytes())完全合法,JVM 会在阻塞点自动挂起虚拟线程,释放底层平台线程去干别的事
  • 无需 CompletableFuture、Reactor 或 @Async,没有回调地狱,异常堆清晰可读

和传统线程池对比:不只是“更快”,而是“更稳”

在同等1000并发 HTTP 请求下:

Zyro AI Image Upscaler
Zyro AI Image Upscaler

Zyro出品的AI图片放大工具

下载

立即学习Java免费学习笔记(深入)”;

  • 固定大小线程池(如 Executors.newFixedThreadPool(50)):50个线程轮流抢活,平均响应延迟高,队列积压严重,超时风险大
  • 缓存线程池(newCachedThreadPool):可能创建上千个平台线程,触发 OS 级上下文切换风暴,内存暴涨甚至 OOM
  • 虚拟线程执行器:只占用约20–50个平台线程(取决于CPU核心数),却能轻松支撑 10万+ 并发任务,内存开销≈每个虚拟线程 2KB 栈空间(远小于平台线程的1MB默认栈)

实际使用要注意的边界

虚拟线程不是银弹,需避开三类典型陷阱:

  • 别在虚拟线程里做 CPU 密集型长任务:比如大数组排序、视频转码。这会独占平台线程,拖慢其他虚拟线程调度。应改用 ForkJoinPool.commonPool() 或专用 CPU 线程池
  • JDBC 驱动必须支持虚拟线程挂起:MySQL Connector/J 8.0.32+、PostgreSQL 42.6.0+ 已适配;旧版驱动仍会阻塞平台线程,抵消虚拟线程优势
  • 不要手动调用 Thread.sleep() 或 wait() 来“模拟延时”:虽然语法合法,但会无谓占用调度资源;测试时建议用 CompletableFuture.delayedExecutor() 替代

小结:用同步思维写异步规模

虚拟线程的价值,不是让你写更多线程,而是让你忘记线程数量这件事。只要任务本质是“等IO”,就用 virtual thread + 同步阻塞调用,JVM 自动完成挂起、恢复、复用。它不取代 NIO,但极大降低了高并发IO编程的认知负荷和出错概率。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
mysql修改数据表名
mysql修改数据表名

MySQL修改数据表:1、首先查看数据库中所有的表,代码为:‘SHOW TABLES;’;2、修改表名,代码为:‘ALTER TABLE 旧表名 RENAME [TO] 新表名;’。php中文网还提供MySQL的相关下载、相关课程等内容,供大家免费下载使用。

686

2023.06.20

MySQL创建存储过程
MySQL创建存储过程

存储程序可以分为存储过程和函数,MySQL中创建存储过程和函数使用的语句分别为CREATE PROCEDURE和CREATE FUNCTION。使用CALL语句调用存储过程智能用输出变量返回值。函数可以从语句外调用(通过引用函数名),也能返回标量值。存储过程也可以调用其他存储过程。php中文网还提供MySQL创建存储过程的相关下载、相关课程等内容,供大家免费下载使用。

493

2023.06.21

mongodb和mysql的区别
mongodb和mysql的区别

mongodb和mysql的区别:1、数据模型;2、查询语言;3、扩展性和性能;4、可靠性。本专题为大家提供mongodb和mysql的区别的相关的文章、下载、课程内容,供大家免费下载体验。

287

2023.07.18

mysql密码忘了怎么查看
mysql密码忘了怎么查看

MySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一,在 WEB 应用方面,MySQL是最好的 RDBMS 应用软件之一。那么mysql密码忘了怎么办呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

519

2023.07.19

mysql创建数据库
mysql创建数据库

MySQL是一个关系型数据库管理系统,由瑞典MySQL AB 公司开发,属于 Oracle 旗下产品。MySQL 是最流行的关系型数据库管理系统之一,在 WEB 应用方面,MySQL是最好的 RDBMS 应用软件之一。那么mysql怎么创建数据库呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

267

2023.07.25

mysql默认事务隔离级别
mysql默认事务隔离级别

MySQL是一种广泛使用的关系型数据库管理系统,它支持事务处理。事务是一组数据库操作,它们作为一个逻辑单元被一起执行。为了保证事务的一致性和隔离性,MySQL提供了不同的事务隔离级别。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

392

2023.08.08

sqlserver和mysql区别
sqlserver和mysql区别

SQL Server和MySQL是两种广泛使用的关系型数据库管理系统。它们具有相似的功能和用途,但在某些方面存在一些显著的区别。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

542

2023.08.11

mysql忘记密码
mysql忘记密码

MySQL是一种关系型数据库管理系统,关系数据库将数据保存在不同的表中,而不是将所有数据放在一个大仓库内,这样就增加了速度并提高了灵活性。那么忘记mysql密码我们该怎么解决呢?php中文网给大家带来了相关的教程以及其他关于mysql的文章,欢迎大家前来学习阅读。

666

2023.08.14

Go高并发任务调度与Goroutine池化实践
Go高并发任务调度与Goroutine池化实践

本专题围绕 Go 语言在高并发任务处理场景中的实践展开,系统讲解 Goroutine 调度模型、Channel 通信机制以及并发控制策略。内容包括任务队列设计、Goroutine 池化管理、资源限制控制以及并发任务的性能优化方法。通过实际案例演示,帮助开发者构建稳定高效的 Go 并发任务处理系统,提高系统在高负载环境下的处理能力与稳定性。

4

2026.03.10

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
MySQL 教程
MySQL 教程

共48课时 | 2.5万人学习

MySQL 初学入门(mosh老师)
MySQL 初学入门(mosh老师)

共3课时 | 0.3万人学习

简单聊聊mysql8与网络通信
简单聊聊mysql8与网络通信

共1课时 | 846人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号