8免费网站建站,asp.net网站设计分工,邢台房产网,备案 网站名字文章目录 使用ExecutorService和Async来使用多线程采用ExecutorService来使用多线程多线程过程的详细解释注意事项优点 使用Async来使用多线程对比Async和ExecutorService的多线程使用方式使用 ExecutorService 的服务类使用 Async 的服务类异步任务类自定义线程池主应用类解释… 文章目录 使用ExecutorService和Async来使用多线程采用ExecutorService来使用多线程多线程过程的详细解释注意事项优点 使用Async来使用多线程对比Async和ExecutorService的多线程使用方式使用 ExecutorService 的服务类使用 Async 的服务类异步任务类自定义线程池主应用类解释运行这个示例注意点 使用ExecutorService和Async来使用多线程
采用ExecutorService来使用多线程
我们直接来通过一段代码来看一下多线程的过程大致就是通过多线程来生成图片
Service
public class NameService {private final ExecutorService executorService Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池public void createImg(String fileNamePrefix) {// 假设我们有一组需要生成的图片ListString imagePrefixes getImagePrefixes(fileNamePrefix);try {for (String prefix : imagePrefixes) {// 提交任务executorService.submit(() - {generateImage(prefix); // 生成图片的方法});}} catch(Exception e) {e.printStackTrace();} finally {// 关闭线程池但允许已提交的任务继续执行executorService.shutdown();// 下面是为了确保线程池关闭手动设置一个时间如果线程60秒没有执行完则强制关闭该线程我这里不需要// try {// if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {// executorService.shutdownNow();// }// } catch (InterruptedException e) {// executorService.shutdownNow();// Thread.currentThread().interrupt();// }}}// 模拟要生成的图片名列表private ListString getImagePrefixes(String fileNamePrefix) {// 获取需要生成的图片前缀列表示例代码return Arrays.asList(fileNamePrefix _1, fileNamePrefix _2, fileNamePrefix _3);}// 生成图片的方法private void generateImage(String prefix) {// 生成图片并保存到本地的方法示例代码System.out.println(Generating image for prefix: prefix);// 实际的图片生成逻辑,这里简单用一个延时函数代替try { Thread.sleep(1000); // 模拟生成图片的时间 } catch (InterruptedException e) { Thread.currentThread().interrupt(); } System.out.println(Generating image for prefix: }
}// 注释相关解释
//awaitTermination等待所有任务在指定时间内完成。如果在指定时间60 秒内所有任务没有完成则调用 executorService.shutdownNow() 强制关闭线程池并中断所有正在执行的任务。
//异常处理处理可能的 InterruptedException确保线程池能够被正确关闭。多线程过程的详细解释
创建线程池 使用 Executors.newFixedThreadPool(10) 创建一个固定大小为 10 的线程池。你可以根据需要调整线程池的大小。提交任务 使用 executorService.submit() 方法将图片生成任务提交给线程池这些任务会被放入线程池的任务队列中等待线程池中的线程来执行。执行任务 线程池中的线程会从任务队列中取出任务并执行。使用的是 ExecutorService 和多线程即使 for 循环结束提交的任务仍会在后台继续运行直到所有任务完成。关闭线程池 调用 executorService.shutdown() 方法后线程池不再接受新任务但会继续执行已经提交的任务直到所有任务执行完毕。如果 generateImage 方法耗时较长那么这些任务会在后台继续运行直到所有任务完成。
多线程使得任务的提交与执行分离。for 循环快速提交任务而线程池在后台并发地执行这些任务。这种异步执行的机制允许你同时处理多个任务而不需要等待每个任务的完成。
注意事项
任务数量确保线程池大小与任务数量合理匹配以免线程过多或过少影响性能。异常处理可以在任务中添加异常处理逻辑确保不会因为某个任务失败而影响其他任务的执行。
优点
提高并发性多个任务可以同时进行提高效率。主线程不中断主线程可以继续执行其他操作而不需要等待每个任务的完成。
使用Async来使用多线程
Spring 提供了 Async 注解用于简化多线程编程。通过这个注解让 Spring 自动管理线程池。
启用异步支持 首先在 Spring Boot 应用中启用异步支持。可以在主应用类或配置类上添加 EnableAsync 注解。
标记异步方法 在需要异步执行的方法上添加 Async 注解。Spring 会在后台线程池中执行这些方法不会阻塞主线程。
具体例子咱们可以通过下面的对比来看。
对比Async和ExecutorService的多线程使用方式
使用 ExecutorService 的服务类
package caj.springboot.service;import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Service;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.List;
import java.util.Arrays;/*** description: 使用 ExecutorService 的服务类* author: CAJ* time: 2025/1/2 20:13*/
Service
public class ExecutorServiceNameService {private final ExecutorService executorService Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池public void createImg(String fileNamePrefix) {ListString imagePrefixes getImagePrefixes(fileNamePrefix);long startTime System.currentTimeMillis();for (String prefix : imagePrefixes) {executorService.submit(() - {generateImage(prefix); // 生成图片的方法});}executorService.shutdown();// 用来判断线程池中的所有任务是否都已经完成。while (!executorService.isTerminated()) {// 等待所有任务完成}long endTime System.currentTimeMillis();System.out.println(ExecutorService 总耗时: (endTime - startTime) 毫秒);}private ListString getImagePrefixes(String fileNamePrefix) {return Arrays.asList(fileNamePrefix _1, fileNamePrefix _2, fileNamePrefix _3);}private void generateImage(String prefix) {try {Thread.sleep(1000); // 模拟生成图片的时间} catch (InterruptedException e) {Thread.currentThread().interrupt();}System.out.println(Generating image for prefix: prefix);}
}使用 Async 的服务类
之后将这个异步方法抽出来了这里面只是调用否则无法异步执行
package caj.springboot.service;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Arrays;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;/*** description:* author: CAJ* time: 2025/1/2 20:13*/
Service
public class AsyncNameService {Autowiredprivate AsyncTask asyncTask;public void createImg(String fileNamePrefix) {ListString imagePrefixes getImagePrefixes(fileNamePrefix);long startTime System.currentTimeMillis();// 下面这样写只是为了确保整个异步过程结束才会记录endTime正常使用就for循环然后调用方法即可ListCompletableFutureVoid futures imagePrefixes.stream().map(prefix - asyncTask.generateImageAsync(prefix)).collect(Collectors.toList());// 等待所有异步任务完成CompletableFutureVoid allOf CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]));try {allOf.get(); // 阻塞等待所有任务完成} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}long endTime System.currentTimeMillis();System.out.println(Async 总耗时: (endTime - startTime) 毫秒);}private ListString getImagePrefixes(String fileNamePrefix) {return Arrays.asList(fileNamePrefix _1, fileNamePrefix _2, fileNamePrefix _3);}// 本来将异步方法直接在这个类中写但是发现无论如何都无法异步执行顾后面将异步方法抽出来
// /**
// * 在异步方法 generateImageAsync 中返回一个 CompletableFuture表示异步任务的完成。
// * param prefix
// * return
// */
// Async(taskExecutor)
// public CompletableFutureVoid generateImageAsync(String prefix) {
// System.out.println(Thread.currentThread().getName() is processing prefix);
// generateImage(prefix);
// return CompletableFuture.completedFuture(null);
// }
//
//
// private void generateImage(String prefix) {
// try {
// Thread.sleep(1000); // 模拟生成图片的时间
// } catch (InterruptedException e) {
// Thread.currentThread().interrupt();
// }
// System.out.println(Generating image for prefix: prefix);
// }
}异步任务类
package caj.springboot.service;import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import java.util.concurrent.CompletableFuture;/*** description: 异步任务类* author: CAJ* time: 2025/1/2 20:52*/
Component
public class AsyncTask {Async(taskExecutor)public CompletableFutureVoid generateImageAsync(String prefix) {generateImage(prefix);return CompletableFuture.completedFuture(null);}private void generateImage(String prefix) {try {Thread.sleep(1000); // 模拟生成图片的时间} catch (InterruptedException e) {Thread.currentThread().interrupt();}System.out.println(Generating image for prefix: prefix);}
}
自定义线程池
Configuration
EnableAsync
public class AsyncConfig {Bean(name taskExecutor)public Executor taskExecutor() {ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor();executor.setCorePoolSize(10);executor.setMaxPoolSize(20);executor.setQueueCapacity(500);executor.setThreadNamePrefix(Async-);executor.initialize();return executor;}
}自定义线程池配置类通过实现 AsyncConfigurer 接口和定义 getAsyncExecutor 方法配置自定义的线程池。自定义线程池参数设置核心线程数、最大线程数、队列容量和线程名前缀。
使用 Async 注解和自定义线程池你可以轻松地将方法异步执行从而提高并发处理能力并优化应用程序性能。
主应用类
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;SpringBootApplication
public class AsyncDemoApplication {public static void main(String[] args) {SpringApplication.run(AsyncDemoApplication.class, args);}BeanCommandLineRunner run(ExecutorServiceNameService executorServiceNameService, AsyncNameService asyncNameService) {return args - {System.out.println(使用 ExecutorService);executorServiceNameService.createImg(test);System.out.println(使用 Async);asyncNameService.createImg(test);};}
}运行结果
使用 ExecutorService
Generating image for prefix: test_2
Generating image for prefix: test_1
Generating image for prefix: test_3
ExecutorService 总耗时: 1003 毫秒
使用 Async
Generating image for prefix: test_2
Generating image for prefix: test_1
Generating image for prefix: test_3
Async 总耗时: 1009 毫秒
由于这里的例子设置时间比较短所以最终时间差不多解释
ExecutorServiceNameService使用 ExecutorService 处理图片生成任务创建一个固定大小为 10 的线程池。AsyncNameService使用 Async 注解让方法异步执行依赖 Spring 管理的线程池。主应用类在应用启动时运行两个服务并输出各自的总耗时以便对比。
运行这个示例
将这两个服务类和主应用类放入项目中运行主应用程序。程序会分别调用 ExecutorServiceNameService 和 AsyncNameService 的 createImg 方法并输出各自的总耗时。
通过这个对比你可以清楚地看到使用 ExecutorService 和 Async 的不同之处以及它们的性能表现。
注意点
为了确保 Async 注解生效可以将异步方法放在一个独立的类中并从主服务类调用这个异步方法。这样Spring AOP 代理能够正确拦截方法调用并应用异步特性因为Spring 使用 AOP 代理来拦截方法调用并提供额外的功能比如事务管理、异步执行等同一个类内部自调用当你在同一个类内部调用带有 Async 注解的方法时Spring AOP 代理无法拦截这个调用从而无法应用异步特性。这是因为代理对象拦截方法调用的前提是调用发生在代理对象本身上而不是在同一个类内部。 文章转载自： http://www.morning.trsmb.cn.gov.cn.trsmb.cn http://www.morning.rkfgx.cn.gov.cn.rkfgx.cn http://www.morning.plflq.cn.gov.cn.plflq.cn http://www.morning.tlzbt.cn.gov.cn.tlzbt.cn http://www.morning.bgbnc.cn.gov.cn.bgbnc.cn http://www.morning.mhlkc.cn.gov.cn.mhlkc.cn http://www.morning.drcnf.cn.gov.cn.drcnf.cn http://www.morning.qhrlb.cn.gov.cn.qhrlb.cn http://www.morning.mqmmc.cn.gov.cn.mqmmc.cn http://www.morning.qcsbs.cn.gov.cn.qcsbs.cn http://www.morning.rrgm.cn.gov.cn.rrgm.cn http://www.morning.yfmxn.cn.gov.cn.yfmxn.cn http://www.morning.kwksj.cn.gov.cn.kwksj.cn http://www.morning.rcbdn.cn.gov.cn.rcbdn.cn http://www.morning.ycgrl.cn.gov.cn.ycgrl.cn http://www.morning.npfrj.cn.gov.cn.npfrj.cn http://www.morning.zwgrf.cn.gov.cn.zwgrf.cn http://www.morning.rbmm.cn.gov.cn.rbmm.cn http://www.morning.fmswb.cn.gov.cn.fmswb.cn http://www.morning.wbxr.cn.gov.cn.wbxr.cn http://www.morning.zrhhb.cn.gov.cn.zrhhb.cn http://www.morning.wjpsn.cn.gov.cn.wjpsn.cn http://www.morning.hjlsll.com.gov.cn.hjlsll.com http://www.morning.lznqb.cn.gov.cn.lznqb.cn http://www.morning.bkpbm.cn.gov.cn.bkpbm.cn http://www.morning.wdhlc.cn.gov.cn.wdhlc.cn http://www.morning.wdply.cn.gov.cn.wdply.cn http://www.morning.cmqrg.cn.gov.cn.cmqrg.cn http://www.morning.xqgh.cn.gov.cn.xqgh.cn http://www.morning.jjzrh.cn.gov.cn.jjzrh.cn http://www.morning.bpmnc.cn.gov.cn.bpmnc.cn http://www.morning.xqbbc.cn.gov.cn.xqbbc.cn http://www.morning.djmdk.cn.gov.cn.djmdk.cn http://www.morning.byywt.cn.gov.cn.byywt.cn http://www.morning.tbkqs.cn.gov.cn.tbkqs.cn http://www.morning.jcwhk.cn.gov.cn.jcwhk.cn http://www.morning.rxfjg.cn.gov.cn.rxfjg.cn http://www.morning.tftw.cn.gov.cn.tftw.cn http://www.morning.zlnmm.cn.gov.cn.zlnmm.cn http://www.morning.cmzgt.cn.gov.cn.cmzgt.cn http://www.morning.mtktn.cn.gov.cn.mtktn.cn http://www.morning.fqqcn.cn.gov.cn.fqqcn.cn http://www.morning.plqqp.cn.gov.cn.plqqp.cn http://www.morning.nhrkl.cn.gov.cn.nhrkl.cn http://www.morning.trsdm.cn.gov.cn.trsdm.cn http://www.morning.ysbhj.cn.gov.cn.ysbhj.cn http://www.morning.kyjpg.cn.gov.cn.kyjpg.cn http://www.morning.mdjzydr.com.gov.cn.mdjzydr.com http://www.morning.nssjy.cn.gov.cn.nssjy.cn http://www.morning.ysgnb.cn.gov.cn.ysgnb.cn http://www.morning.ybgt.cn.gov.cn.ybgt.cn http://www.morning.dwtdn.cn.gov.cn.dwtdn.cn http://www.morning.zrmxp.cn.gov.cn.zrmxp.cn http://www.morning.lhxrn.cn.gov.cn.lhxrn.cn http://www.morning.wjlhp.cn.gov.cn.wjlhp.cn http://www.morning.tbbxn.cn.gov.cn.tbbxn.cn http://www.morning.jfwbr.cn.gov.cn.jfwbr.cn http://www.morning.dtnyl.cn.gov.cn.dtnyl.cn http://www.morning.lmfmd.cn.gov.cn.lmfmd.cn http://www.morning.wxqmc.cn.gov.cn.wxqmc.cn http://www.morning.ccyjt.cn.gov.cn.ccyjt.cn http://www.morning.rbnj.cn.gov.cn.rbnj.cn http://www.morning.sfswj.cn.gov.cn.sfswj.cn http://www.morning.ykrkb.cn.gov.cn.ykrkb.cn http://www.morning.wpcfm.cn.gov.cn.wpcfm.cn http://www.morning.lcplz.cn.gov.cn.lcplz.cn http://www.morning.tgfjm.cn.gov.cn.tgfjm.cn http://www.morning.rfgc.cn.gov.cn.rfgc.cn http://www.morning.bkgfp.cn.gov.cn.bkgfp.cn http://www.morning.ybyln.cn.gov.cn.ybyln.cn http://www.morning.mknxd.cn.gov.cn.mknxd.cn http://www.morning.lhxkl.cn.gov.cn.lhxkl.cn http://www.morning.ltqtp.cn.gov.cn.ltqtp.cn http://www.morning.zhmgcreativeeducation.cn.gov.cn.zhmgcreativeeducation.cn http://www.morning.kgmkl.cn.gov.cn.kgmkl.cn http://www.morning.rsxw.cn.gov.cn.rsxw.cn http://www.morning.lzzqz.cn.gov.cn.lzzqz.cn http://www.morning.jypsm.cn.gov.cn.jypsm.cn http://www.morning.wdply.cn.gov.cn.wdply.cn http://www.morning.yunease.com.gov.cn.yunease.com
