2026/1/8 7:16:55
网站建设
项目流程
怎么做网站标题优化,营销战略有哪些内容,晋江+网站建设+推广,怎么做自己的网站卖东西前言
JDK21可以说是一个史诗级的产品#xff0c;带来了目前Java高并发较为顶级解决方案虚拟线程 #xff0c;话不多说#xff0c;直接来上代码体验一下功能#xff0c;洛阳目前使用的笔记本是华为的matebook D15 2022款#xff0c;16512#xff0c;cpu是i7-1195G7#…前言JDK21可以说是一个史诗级的产品带来了目前Java高并发较为顶级解决方案虚拟线程话不多说直接来上代码体验一下功能洛阳目前使用的笔记本是华为的matebook D15 2022款16512cpu是i7-1195G7idea2024.1.7所有都是使用默认配置话不多说上代码全部代码在最后正文先是一个模拟IO操作的方法// 模拟工作负载的方法privatestaticvoidsimulateWork(){try{// 模拟一个耗时100毫秒的I/O操作Thread.sleep(100);}catch(InterruptedExceptione){// 如果线程被中断重新设置中断状态Thread.currentThread().interrupt();}}使用虚拟线程的测试代码// 使用虚拟线程执行任务的方法privatestaticlongexecuteWithVirtualThreads(inttaskCount)throwsInterruptedException{// 记录开始时间longstartSystem.currentTimeMillis();// 创建一个虚拟线程执行器try(ExecutorServiceexecutorExecutors.newVirtualThreadPerTaskExecutor()){// 提交taskCount个任务到虚拟线程执行器for(inti0;itaskCount;i){executor.submit(Test::simulateWork);}// 关闭执行器不再接受新任务executor.shutdown();// 等待所有任务完成最多等待1小时executor.awaitTermination(1,TimeUnit.HOURS);}// 计算并返回总耗时returnSystem.currentTimeMillis()-start;}使用线程池的测试代码// 使用传统线程执行任务的方法privatestaticlongexecuteWithTraditionalThreads(inttaskCount)throwsInterruptedException{// 记录开始时间longstartSystem.currentTimeMillis();// 创建一个固定大小为100的线程池try(ExecutorServiceexecutorExecutors.newFixedThreadPool(100)){// 提交taskCount个任务到线程池for(inti0;itaskCount;i){executor.submit(Test::simulateWork);}// 关闭线程池不再接受新任务executor.shutdown();// 等待所有任务完成最多等待1小时executor.awaitTermination(1,TimeUnit.HOURS);}// 计算并返回总耗时returnSystem.currentTimeMillis()-start;}格式化时间可有可无// 格式化时间的方法将毫秒转换为更易读的格式privatestaticStringformatTime(longmilliseconds){// 返回格式化的字符串同时显示毫秒数和秒数保留两位小数returnString.format(%d 毫秒 (%.2f 秒),milliseconds,milliseconds/1000.0);}main方法publicstaticvoidmain(String[]args)throwsInterruptedException{// 设置要执行的任务数量inttaskCount100000;// 开始测试传统线程System.out.println(正在使用传统线程执行任务...);// 执行传统线程测试并记录耗时longtraditionalTimeexecuteWithTraditionalThreads(taskCount);// 输出传统线程的执行时间System.out.println(传统线程完成任务耗时 formatTime(traditionalTime));// 开始测试虚拟线程System.out.println(\n正在使用虚拟线程执行任务...);// 执行虚拟线程测试并记录耗时longvirtualTimeexecuteWithVirtualThreads(taskCount);// 输出虚拟线程的执行时间System.out.println(虚拟线程完成任务耗时 formatTime(virtualTime));// 计算两种线程执行时间的差异longtimeDifferencetraditionalTime-virtualTime;// 输出性能差异和速度提升倍数System.out.println(\n性能差异formatTime(timeDifference) (String.format(%.2f,(double)traditionalTime/virtualTime) 倍速度提升));}运行结果正在使用传统线程执行任务...传统线程完成任务耗时106725毫秒(106.73秒)正在使用虚拟线程执行任务...虚拟线程完成任务耗时2014毫秒(2.01秒)性能差异104711毫秒(104.71秒)(52.99倍速度提升)Processfinishedwithexitcode0可以看到使用了虚拟线程之后速度提升了50倍左右至于底层原理之类的那不是洛阳这种小垃圾去看的洛阳只学会能够如何使用就可以了手动狗头以下是整个测试类的完整代码大家可以自己跑一下感受一下但是虚拟线程也并不是说能够无脑上要根据实际情况考虑正所谓没有最好的架构、只有最合适的架构。packagecom.travel.echo.test;importjava.util.concurrent.ExecutorService;importjava.util.concurrent.Executors;importjava.util.concurrent.TimeUnit;/** * Description * Author LuoYang * Date 2025/12/6 周六 */publicclassTest{publicstaticvoidmain(String[]args)throwsInterruptedException{// 设置要执行的任务数量inttaskCount100000;// 开始测试传统线程System.out.println(正在使用传统线程执行任务...);// 执行传统线程测试并记录耗时longtraditionalTimeexecuteWithTraditionalThreads(taskCount);// 输出传统线程的执行时间System.out.println(传统线程完成任务耗时 formatTime(traditionalTime));// 开始测试虚拟线程System.out.println(\n正在使用虚拟线程执行任务...);// 执行虚拟线程测试并记录耗时longvirtualTimeexecuteWithVirtualThreads(taskCount);// 输出虚拟线程的执行时间System.out.println(虚拟线程完成任务耗时 formatTime(virtualTime));// 计算两种线程执行时间的差异longtimeDifferencetraditionalTime-virtualTime;// 输出性能差异和速度提升倍数System.out.println(\n性能差异formatTime(timeDifference) (String.format(%.2f,(double)traditionalTime/virtualTime) 倍速度提升));}// 使用传统线程执行任务的方法privatestaticlongexecuteWithTraditionalThreads(inttaskCount)throwsInterruptedException{// 记录开始时间longstartSystem.currentTimeMillis();// 创建一个固定大小为100的线程池try(ExecutorServiceexecutorExecutors.newFixedThreadPool(100)){// 提交taskCount个任务到线程池for(inti0;itaskCount;i){executor.submit(Test::simulateWork);}// 关闭线程池不再接受新任务executor.shutdown();// 等待所有任务完成最多等待1小时executor.awaitTermination(1,TimeUnit.HOURS);}// 计算并返回总耗时returnSystem.currentTimeMillis()-start;}// 使用虚拟线程执行任务的方法privatestaticlongexecuteWithVirtualThreads(inttaskCount)throwsInterruptedException{// 记录开始时间longstartSystem.currentTimeMillis();// 创建一个虚拟线程执行器try(ExecutorServiceexecutorExecutors.newVirtualThreadPerTaskExecutor()){// 提交taskCount个任务到虚拟线程执行器for(inti0;itaskCount;i){executor.submit(Test::simulateWork);}// 关闭执行器不再接受新任务executor.shutdown();// 等待所有任务完成最多等待1小时executor.awaitTermination(1,TimeUnit.HOURS);}// 计算并返回总耗时returnSystem.currentTimeMillis()-start;}// 模拟工作负载的方法privatestaticvoidsimulateWork(){try{// 模拟一个耗时100毫秒的I/O操作Thread.sleep(100);}catch(InterruptedExceptione){// 如果线程被中断重新设置中断状态Thread.currentThread().interrupt();}}// 格式化时间的方法将毫秒转换为更易读的格式privatestaticStringformatTime(longmilliseconds){// 返回格式化的字符串同时显示毫秒数和秒数保留两位小数returnString.format(%d 毫秒 (%.2f 秒),milliseconds,milliseconds/1000.0);}}结尾悲观者永远正确 乐观者永远前行