文档建议反馈控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

CompletableFuture Java多线程操作

意味着会在主线程之外创建一个独立的线程，与主线程分隔开，并在上面运行一个非阻塞的任务，然后通知主线程成功或者失败。...一种是supply开头的方法，一种是run开头的方法 supply开头：这种方法，可以返回异步线程执行之后的结果 run开头：这种不会返回结果，就只是执行线程任务 或者可以通过一个简单的无参构造器 CompletableFuture... completableFuture = new CompletableFuture(); 在实例化方法中，我们是可以指定Executor参数的，当我们不指定的试话，我们所开的并行线程使用的是默认系统及公共线程池...我们在编程的时候需要谨慎使用守护线程，如果将我们普通的用户线程设置成守护线程，当我们的程序主线程结束，JVM中不存在其余用户线程，那么CompletableFuture的守护线程会直接退出，造成任务无法完成的问题...int i = result; return i; }).thenApply(result -> { // 这里不会执行

69830
    • 您找到你想要的搜索结果了吗？
    是的
    没有找到

    03-CompletableFuture异步线程 扩展

    执行一个线程任务(开启新的线程去执行),没有入参,没有返回值 thenCombine 用于合并两个线程的返回值,第一个参数就是(第二个线程任务),第二个参数是传入一个函数式接口,传入x,...用于线程任务合并(开启新的线程去执行),关注返回值 thenAcceptBoth 用于合并两个线程的返回值,第一个参数就是(第二个线程任务),第二个参数是传入一个函数式接口,传入x,y...用于线程任务合并(开启新的线程去执行),不关注返回值 runAfterBoth 用于合并两个线程的返回值,第一个参数就是(第二个线程任务),第二个参数是传入一个Runnable接口...用于线程任务合并(开启新的线程去执行),没有入参,不关注返回值 applyToEither 用于处理两个线程那个优先完成,第一个参数就是(第二个线程任务),第二个参数是一个函数式接口,传入...用于处理两个线程那个优先完成就用那个的返回值(开启新的线程去执行),传入的x就是优先线程返回的结果,关注返回值 acceptEither 用于处理两个线程那个优先完成,第一个参数就是(第二个线程任务

    22630

    04-CompletableFuture异步线程 性能

    场景 场景 方法 任务少, 不频繁 直接使用线程 任务数稳定,频繁 使用线程池 线程池 优点 不用频繁的创建和销毁线程 不需要担心OOM...直接往任务队列添加任务即可 核心线程忙不过来,可以自动增加到最大线程数 构造参数 核心线程数 最大线程数 空闲活跃时长 时长单位 阻塞队列 线程工厂 拒绝策略 直接丢弃 替换最后一个 抛异常 谁提交的任务谁执行...创建一个无上限的线程池(Integer.MAX) newFixedThreadPool 创建一个固定线程数的线程池 需求 小白和他的朋友门,连续输了10几把游戏, 决定去餐厅吃饭了...(CompletableFuture.runAsync(dish::make))); // 将所有线程统一join CompletableFuture.allOf(completableFutures.toArray...原因 隔离, 防止影响其他使用ForkJoinPool的代码 方便控制, ForkJoinPool在初始化后, 不可以修改, 但是自定义的线程池可以在任务数量来之后, 通过计算得出线程的数量 这里采用无上限线程池演示

    32710

    01-CompletableFuture异步线程 入门

    ,线程的创建,回收,管理,池化,都很难弄, 但是学习了这个东西, 妈妈再也不用担心我用不好多线程了 CompletableFuture是什么 从名称看来和Future有关,没错,他也是Future的实现...; import java.util.concurrent.CompletableFuture; public class CompletableFutureTest { @Test..., 异步线程,如此简单 需求进化 在餐厅中一般厨师都只负责炒菜,像打饭这样的事情都是交给服务员来的 需求点:厨师炒完菜后交给服务员,服务员新开线程去打饭 实现 编写代码 @Test public void...testTwo(){ print("小白进入餐厅"); print("小白点了 番茄炒蛋 + 一碗米饭"); CompletableFuture cf1 = CompletableFuture.supplyAsync...第二个任务的需求点在于两个线程的连接 第三个任务的需求点在于两个线程的结果合并 怎么样到这里是不是已经简单的入门了呢 作者：彼岸舞 时间：2022\04\11 内容关于：CompeletableFuture

    22130

    JUC-Java多线程Future，CompletableFuture

    一般情况下不做特别说明配置，默认都是用户线程 用户线程（User Thread）: 是系统的工作线程，它会完成这个程序需要完成的业务条件。...守护线程（Daemon Thread）：是一种特殊的线程为其它线程服务的，在后台默默地完成一些系统性的服务 守护线程作为一个服务线程，没有服务对象就没有必要继续运行了 ，如果用户线程全部结束了，意味着程序需要完成的业务操作已经结束了...比如主线程让一个子线程去执行任务，子线程可能比较耗时，启动子线程开始执行任务后，主线程就去做其他事情了，忙其他事情或者执行完，过了一会才去获取子任务的执行结果或变更的任务状态。...join和get区别 在编译时是否报出检查型异常 CompletableFuture的优点 异步任务结束时，会自动回调某个对象的方法 主线程设置好回调后，不再关心异步任务的执行，异步任务之间可以顺序执行...没有传入自定义线程池，都用默认线程池ForkJoinPool 如果执行第一个任务的时候，传入一个自定义线程池 调用thenRun方法执行第二个任务时，则第二个任务和第一个任务时使用同一个线程池

    42630

    优化排查-线程阻塞：CompletableFuture 和 DiscardPolicy

    优化排查-线程阻塞：CompletableFuture 和 DiscardPolicy 问题发现 1 前天大佬通过prometheus发现 tomcat http busy状态的线程这几天呈线性递增。...每一天增加3个 排查问题 1：找到busy线程在哪。...凌晨左右调度了十次，失败了三次，和在prometheus发现的 busy http线程增加的规律是一致的 4 查找代码发现是 CompletableFuture 调用get阻塞住了。...4.1 promethues 监控到的线程队列数为空 5 没有任务 CompletableFuture 的get方法还在执行，查看下 verifiedCodeQueryExecutor 的定义。...也就是任务丢弃了不被执行，而封装成的CompletableFuture 自然就不会有结果返回，因此一直会被阻塞，而改了代码则是超时返回。真相大白。。。。。

    88150

    优化排查-线程阻塞：CompletableFuture 和 DiscardPolicy

    优化排查-线程阻塞：CompletableFuture 和 DiscardPolicy 问题发现 1 前天大佬通过prometheus发现 tomcat http busy状态的线程这几天呈线性递增。...每一天增加3个 排查问题 1：找到busy线程在哪。...凌晨左右调度了十次，失败了三次，和在prometheus发现的 busy http线程增加的规律是一致的 4 查找代码发现是 CompletableFuture 调用get阻塞住了。...4.1 promethues 监控到的线程队列数为空 5 没有任务 CompletableFuture 的get方法还在执行，查看下 verifiedCodeQueryExecutor 的定义。...也就是任务丢弃了不被执行，而封装成的CompletableFuture 自然就不会有结果返回，因此一直会被阻塞，而改了代码则是超时返回。真相大白。。。。。

    83750

    CompletableFuture 异步多线程，那叫一个优雅

    } 「运行结果」： 第一个执行结果为 「商品B」，因为要先睡上1秒结果不能立即获取 join方法获取结果方法里不会抛异常，但是执行结果会抛异常，抛出的异常为CompletionException...区别在于： 「runAfterBoth」 不会把执行结果当做方法入参，且没有返回值 「thenAcceptBoth」: 会将两个任务的执行结果作为方法入参，传递到指定方法中，且无返回值 「thenCombine...//反例 CompletableFuture.get(); //正例 CompletableFuture.get(5, TimeUnit.SECONDS); 3、不建议使用默认线程池 CompletableFuture...并且一般建议使用自定义线程池。 但是如果线程池拒绝策略是DiscardPolicy或者DiscardOldestPolicy，当线程池饱和时，会直接丢弃任务，不会抛弃异常。...因此建议，CompletableFuture线程池策略最好使用AbortPolicy，然后耗时的异步线程，做好线程池隔离哈。

    1.6K20

    Java编码指南:慎用CompletableFuture中不带线程池参数的那些方法

    ---- CompletableFuture提供异步执行的方法总是成对的 ---- 例如： java.util.concurrent.CompletableFuture#supplyAsync...ForkJoinPool.commonPool() : new ThreadPerTaskExecutor(); CompletableFuture提供异步执行的方法，强制使用显示提供线程池 ---...1、默认提供的线程池，会使得相关的异步执行都共用一个线程池，不合理；而且不能相互隔离业务的执行；线程池的参数也不能改变； 2、默认提供的线程池，在微服务spring cloud环境中，会丢失链路信息，...ForkJoinPool，使得线程上下文类加载器ContextClassLoader固定为SystemClassLoader，容易导致类加载失败； 小结 ---- CompletableFuture提供异步执行的方法...，强制使用显示提供线程池，能避免上述提到的一些问题。

    44730

    Java8已经发布7年了，不会还有人没用过CompletableFuture吧

    但是当你用过CompletableFuture之后，就会发现以前的线程池处理任务有多难用，功能有多简陋，CompletableFuture又是多么简洁优雅。...代码经过CompletableFuture改造后，是多么的简洁优雅。提交任务也不用再关心线程池是怎么使用了，获取结果也不用再阻塞当前线程了。...CompletableFuture更多妙用3.1 等待所有任务执行完成如果让你实现等待所有任务线程执行完成，再进行下一步操作，你会怎么做？...十年前可以这样写，Java8都已经发布7年了，你还不会用Java8的写法？...获取结果join 阻塞等待，不会抛异常get 阻塞等待，会抛异常complete(T value) 不阻塞，如果任务已完成，返回处理结果。如果没完成，则返回传参value。

    49910

    手把手教你线程池配合CompletableFuture实现图片下载并压缩

    i<threadNum; i++){ threadS.add(i); } 首先我们保存了需要下载的图片的 Url 列表，多线程的方式下载我们需要保证每个线程下载的图片不会重复，因此我们需要根据规则来切割保存...// 如item=10,也就是线程数为10,则直接执行10次(有线程池的前提下) threadS.stream().map(item -> CompletableFuture.runAsync((...imageInfoVos.size() 此次是为了保证最后一个线程处理最后不足的图片 ❞ 根据如上规则即可得到每个线程需要下载的图片Url保证不会重复 // 根据item数值通过sublist 从开始到结束...(dataNum * (item + 1 )=100 // 根据如上规则即可得到每个线程需要下载的图片Url保证不会重复 // (item+1)==threadNum?...本文从一个实践的真实项目场景出发，教大家使用上 CompletableFuture，线程池等知识点。

    82210

    Android 主线程中 Looper.loop() 为什么不会卡死主线程？

    Message.obtain()获取Message时候可以减少对象的创建 msg.recycleUnchecked(); } } Looper.loop() 为什么不会卡死主线程...此时主线程会释放CPU资源进入休眠状态，直到下个消息到达或者有事务发生，通过往pipe管道写端写入数据来唤醒主线程工作。...2,在进入死循环之前创建了新binder线程，在代码ActivityThread.main()中, thread.attach(false)；便会创建一个Binder线程（具体是指ApplicationThread...，Binder的服务端，用于接收系统服务AMS发送来的事件），该Binder线程通过Handler将Message发送给主线程. public static void main(String[] args...throw new RuntimeException("Main thread loop unexpectedly exited"); } 所以 在 Looper.loop() 中阻塞的时候不会卡死主线程

    1.5K10

    一次性解决老大难问题：线程治理 Futrue、Callable接口、CompletableFuture

    ----一次性解决老大难问题：线程治理 Futrue、Callable接口、CompletableFuture线程治理最重要的是线程池了，之前我讲过，但是，还有两大法宝就是future 和 callable...为何需要callable，不是有runnable了吗runnable的缺陷1、不能返回值，子线程去做任务的时候，它是不会返回结果的也就是run方法，在runnable接口里是void返回值，我们重写了之后...springboot中，@Async，通过的也是线程池当前的Task再那个线程执行，由方法命名控制xxxAsync表示异步，在线程池中执行， 没用指定线程池的情况下，使用CompletableFuture...内部线程池ForkJoinPool,线程数默认是cpu核数 需要注意线程池在业务层面划分，避免慢因为慢的io操作影响整体性能小结：completableFuture是对Futrue异步特性的加强，实现了...CompletableFuture> 用thenCompose组合起来，就不会有这个问题，public class Product { private int id; private

    92110

    【小家Java】Future、FutureTask、CompletionService、CompletableFuture解决多线程并发中归集问题的效率对比

    当2个以上线程同时尝试完成、异常完成、取消一个CompletableFuture时，只有一个能成功。...CompletableFuture实现了CompletionStage接口的如下策略： 为了完成当前的CompletableFuture接口或者其他完成方法的回调函数的线程，提供了非异步的完成操作 没有显式入参...为了简化监视、调试和跟踪，所有生成的异步任务都是标记接口AsynchronousCompletionTask的实例 所有的CompletionStage方法都是独立于其他共有方法实现的，因此一个方法的行为不会受到子类中其他方法的覆盖...，构造后CompletableFuture完成 anyOf是只要有一个任务完成，构造后CompletableFuture就完成 public static CompletableFutureCompletableFuture，返回结果get()获取 /** * 多线程并发任务,取结果归集 * * @author fangshixiang@vipkid.com.cn

    2.6K32

    【译】CompletableFuture 是否非阻塞

    相比之下，非阻塞操作允许线程在不必等待每个任务完成的情况下同时执行多个计算。 当前线程可以在其他线程并行执行任务的同时继续执行： 在上面的例子中，_线程2_不会阻塞_线程1_的执行。...但是，_CompletableFuture _在完成后不会通知我们。 如果需要，我们可以使用 _get() _方法在调用线程中检索结果。...()); 这两种方法之间的主要区别是，如果未来异常完成，_join() _方法不会抛出已检查的异常。...然而，当需要在调用线程中获取计算结果时，我们可以创建_CompletableFuture_，在当前线程中执行其他工作，然后调用_get()_或_join()_方法。...但仍然不能保证检索不会阻塞线程。 6. 结论 在本文中，我们探讨了 _CompletableFuture _ 是非阻塞的情况以及不是非阻塞的情况。

    71240
    点击加载更多

    扫码

    添加站长 进交流群

    领取专属 10元无门槛券

    手把手带您无忧上云

    扫码加入开发者社群

    相关资讯

    热门标签

    更多标签

    活动推荐

      运营活动

      活动名称
      广告关闭

      腾讯云开发者

      扫码关注腾讯云开发者

      扫码关注腾讯云开发者

      领取腾讯云代金券

      热门产品

      热门推荐

      更多推荐

      Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有

      深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 深公网安备号 44030502008569

      腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号 | 京公网安备号11010802020287

      领券