那个做我女朋友的网站,学校建设网站费用申请报告,wordpress开发小程序,宜阳建站在实际项目开发过程中#xff0c;大部分程序的执行顺序都是按照代码编写的先后顺序#xff0c;依次从上往下挨个执行的#xff0c;但是对于统计或者批量操作数据时#xff0c;是否有更好的方案呢#xff1f;这时候就可以考虑使用多线程编程#xff0c;异步并行执行多个任…在实际项目开发过程中大部分程序的执行顺序都是按照代码编写的先后顺序依次从上往下挨个执行的但是对于统计或者批量操作数据时是否有更好的方案呢这时候就可以考虑使用多线程编程异步并行执行多个任务从而提升用户使用体验发挥多核cpu的性能。
更多关于CompletableFuture的说明请参看如下文章
Java多线程之CompletableFuture_java completablefuture-CSDN博客
Java中的CompletableFuture原理与用法_java_脚本之家
以下文案是基于数据统计方案去设计编写的希望可以对各位有所帮助。
一.CompletableFuture是什么
CompletableFuture是由Java8引入的用于异步编程异步通常意味着非阻塞运行任务单独的线程与主线程隔离。并且通过回调可以在主线程中得到异步任务的执行状态是否完成和异常等信息。通过这种方式编程主线程不会被阻塞不需要等到多个子线程执行完成它可以并行执行其他任务。使用这种并行编程方式可以极大的提高程序的执行和运行效率提升用户使用体验等。 与Future对比
CompletableFuture默认使用的是ForkJoinPool线程池CompletableFuture 是 Future API的扩展Future在实际使用过程中存在局限性如不支持异步任务的编排组合获取计算结果的get() 方法为阻塞调用CompletableFuture除了提供了更为好用和强大的 Future 特性之外还提供了函数式编程、异步任务编排组合等扩展功能。 二.如何创建CompletableFuture实例
1. supplyAsync()
通过该函数创建的CompletableFuture实例会异步执行当前传入的计算任务。在调用端则可以通过get或join获取最终计算结果。
/**
* 有返回值的
* 如果不指定线程池默认的构造方法使用ForkJoinPool
**/
ExecutorService executorService Executors.newFixedThreadPool(4);
CompletableFutureListSysDept cfDeptList CompletableFuture.supplyAsync(() - {return remoteStationService.getAllStationInfo(0).getData();},executorService);
ListSysDept join cfDeptList.join();
2.runAsync()
与supplyAsync()不同的是runAsync()传入的任务要求是Runnable类型的所以没有返回值。因此runAsync适合创建不需要返回值的计算任务。
//无返回值
CompletableFuture cf CompletableFuture.runAsync(()-{getFireFightingData(params,resultAll);},fjp);
3.Future.get()和CompletableFuture.join()对比
这两个方法都是阻塞方法用于获取异步任务的结果。Future.get()方法在获取异步任务结果时更具灵活性因为它必须声明抛出异常且需要手动处理同时它会阻塞线程调用。CompletableFuture.join() 方法更适用于使用 ForkJoinPool 线程池执行任务的情况它更方便用于不会阻塞 ForkJoinPool 线程池中的线程中。
三.CompletableFuture使用 //仅展示部分关键代码 ForkJoinPool fjp new ForkJoinPool(8);System.out.println(默认使用的线程为: Thread.currentThread().getName());CompletableFuture cf1 CompletableFuture.runAsync(()-{System.out.println(cf1使用的线程为: Thread.currentThread().getName());//站数据ListStationDTO stationAllVoList staMapper.getAllStationVoList(null);MapString, StationDTO stationAllVoMap null;if(CollectionUtils.isNotEmpty(stationAllVoList)){stationAllVoMap stationAllVoList.stream().collect(Collectors.toMap(StationDTO::getStationName, Function.identity()));}else {stationAllVoMap new HashMap();}resultAll.put(stationAllVoMap,stationAllVoMap);},fjp);System.out.println(cf1使用完之后的线程为: Thread.currentThread().getName());CompletableFuture cf2 CompletableFuture.runAsync(()-{System.out.println(cf2使用的线程为: Thread.currentThread().getName());getSafetyCountData(params,resultAll);},fjp);CompletableFuture cf3 CompletableFuture.runAsync(()-{System.out.println(cf3使用的线程为: Thread.currentThread().getName());getRectifyRateData(params,resultAll);},fjp);CompletableFuture cf4 CompletableFuture.runAsync(()-{System.out.println(cf3使用的线程为: Thread.currentThread().getName());getAlarmARemindData(params,resultAll);},fjp);CompletableFuture.allOf(cf1,cf2,cf3,cf4).join();fjp.shutdown();需要注意的点
allOf()返回的CompletableFuture是多个任务都执行完成后才会执行只要有一个任务执行异常则返回的CompletableFuture执行get方法时会抛出异常如果都是正常执行则get返回null。anyOf()返回的CompletableFuture是多个任务只要其中一个执行完成就会执行其get返回的是已经执行完成的任务的执行结果如果该任务执行异常则抛出异常。
四. 模拟测试验证 经过测试 多个子线程执行并不会影响主线程的继续执行也不存在线程阻塞问题与设计效果保持一致非常值得借鉴学习。
