completable-future 相关问题

在Java 8中,可以显式完成的Future(设置其值和状态),并且可以包括在完成时触发的依赖函数和动作。

使用 Spring @Async 与直接使用 CompleteableFuture 相比有什么优势?

使用 Spring Async 与自己返回 CompletableFuture 相比有什么优势?

回答 3 投票 0

为什么 CompletableFuture runAsync 在我的代码中不起作用?

我有示例代码,例如 私有布尔 exampleFunc(长 id) { 信息信息=新信息(); info.setCustomerId(100L); var res = CompletableFuture.runAsync(() -> exampleApi.doFunc(info)); 返回

回答 1 投票 0

CompletableFuture 有时可能为 null 如何处理

我有这些CompletableFutures: 完整的未来 futureA = createFutureA(multipleItems, startDate, 源, 上下文); 完整的未来未来B = 创建FutureB(

回答 1 投票 0

为什么执行器服务提交的任务没有异步执行任务?

我正在尝试在我的 intellij 本地中使用异步 java。我的意图是,我将从 main 方法调用 calucalateAsync() 方法,然后将调试点放在 System.out.println("calculate

回答 1 投票 0

如何实现 CompletableFuture.allOf() 在任何 future 失败时异常完成?

我想实现 CompletableFuture.allOf() 和 CompletableFuture.anyOf() 的混合,其中一旦所有元素成功完成,返回的 future 就会成功完成,否则

回答 3 投票 0

Junit Test 在 CompletableFuture.allof().join 上无限卡住

我正在为实现 CompletableFuture 的类编写 Junit 测试。我试图模拟这段代码,但测试无限地卡在 CompletableFuture.allOf(future1,future2) 上......

回答 2 投票 0

PowerMockito verifyStatic:验证对静态方法的异步调用

我正在通过静态方法调用外部系统 MyExternalServiceAccessor.myMethod(param1, param2); 到目前为止,我已经使用 PowerMockito 的 verifyStatic 进行了单元测试,如下所示 我...

回答 1 投票 0

如何利用协程/completeableFuture<> spring boot应用程序来提高吞吐量

所以,我的服务层中有一个外部 Api 调用和 2 个繁重的数据库查询,阻塞代码如下所示 覆盖 fun getTotalIncomeByMonth(retailerMsisdn: String, 月份: Int, 年: Int):

回答 1 投票 0

CompletableFuture 的安全上下文为空

我有一个奇怪的问题。 鉴于此代码: @RequestMapping(值 = {"/randomizer"}, 方法 = RequestMethod.POST) 公共 CompletableFuture 随机化器(){ 可以完成...

回答 2 投票 0

@async 在 Spring Boot 中无法按预期工作

我正在尝试进行并行休息通话。 我已经在类本身中设置了这样的执行器。 ThreadPoolTaskExecutor 执行器 = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(5)...

回答 1 投票 0

Java Completable future中的supplyAsync线程在不同的环境下使用不同的线程

在我的 Web 应用程序中,supplyAsync 方法在云 Linux 环境中使用 forkjoin 池,但在本地 Linux 计算机中,相同的代码使用诸如 thread-1 thread-2 之类的线程和类 Web 应用程序类加载器。有没有...

回答 1 投票 0

如何测试CompletableFuture.supplyAsync方法的supplier方法中传递的私有方法?

我想为一个公共方法编写junit测试,该方法使用CompletableFuture.supplyAsync来处理一些数据,然后将其保存到数据库。然而,传递的供应商方法包含一个私有方法

回答 1 投票 0

使用 CompletableFuture 抛出已检查的异常

Stackoverflow 包含多个有关将检查异常与 CompletableFuture 混合的问题。 这里有一些例子: 使用 CompletableFuture 检查异常 Java 8 供应商异常处理...

回答 2 投票 0

丢失了来自 CompletableFuture.allOf 的一些请求

问题是我必须一一调用API,所以我使用CompleableFunction,如下所示 List> completableFutures = new ArrayList<>(); 列表 列表...

回答 2 投票 0

CompletableFuture<T> 类:join() 与 get()

CompletableFuture类的get()和join()方法有什么区别? 下面是我的代码: 列表过程(){ 列表消息 = Arrays.a...

回答 3 投票 0

在应用程序中使用 Future 块 UI

在我的 Android 应用程序中,我想使用 java.util.concurrent 工具来进行返回值的操作(用于教育目的)。我读到 Future with Callable 可以用于此目的。我做了一个项目......

回答 1 投票 0

JAVA中有限线程以非阻塞方式CompletableFuture运行任务

我定义了两个线程池,如下所示: 执行器 executor = Executors.newFixedThreadPool(2); 现在我有三个任务,其中 2 个是阻塞的,其中一个是非阻塞的 完整的未来...

回答 1 投票 0

thenApply() 是否仅依赖于第一个方法?

公开课测试{ 公共静态CompletableFuturefirstMethod(int x){ // 假设此方法在 8 秒内完成。 返回 CompletableFuture.supplyAsync(() -> {...

回答 1 投票 0

如何创建一个在调用 CompletableFuture::get 之前不计算的 CompletableFuture?

标题大部分是不言自明的。我正在尝试解决一个问题,但为了做到这一点,我需要 CompletableFuture 在有人开始通过 CompletableFu 运行它之前不要尝试执行...

回答 1 投票 0

有没有办法创建一个未启动的CompletableFuture?喜欢 Thread.Builder::unstarted?

标题大部分是不言自明的。我正在尝试解决一个问题,但为了做到这一点,我需要 CompletableFuture 在有人开始通过 CompletableFu 运行它之前不要尝试执行...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.