completable-future 相关问题

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

为什么我的Thread.sleep进入CompletableFuture时会结束我的进程?

我正在尝试创建CompleteableFuture。我只是想注销一些声明。这是我的代码:static CompletableFuture createFuture(String name){return ...

回答 1 投票 0

是否有可能在创建它的同一线程中运行可完成的未来?

想知道一个completablefuture是否可以在创建它的线程中运行。您可能会问为什么我需要这样做,因为completablefuture用于异步编程。原因是...

回答 1 投票 1

我如何模拟可完成的Future的supplyAsync方法响应?

public class Test {public Obj func(){CompletableFuture completableFuture = CompletableFuture.supplyAsync(new ContextSupplier {public Obj onGet(){...

回答 1 投票 0

带有确认的海王星下降顶点属性

我曾尝试通过Gremlin Tinkerpop查询来查询Amazon neptune,以删除Vertex的属性。它工作正常,但是在删除属性时无法得到TRUE / FALSE的确认。但是,我可以管理...

回答 1 投票 0

关于使用CompletableFuture的建议

我希望使用CompletableFuture进行一些推荐。如果我有一个整数列表,则对于每个整数,我想执行3个动作,这需要一些时间。例如,乘法,除法和...

回答 2 投票 0

使用CompletableFuture的最佳实践

我想知道使用CompletableFuture的最佳实践。如果我有一个整数列表,则对于每个整数,我想执行3个动作,这需要一些时间。例如,乘以...

回答 2 投票 0

带有Future和completableFuture的中断读取方法

在解决任务时,我注意到无法解释的行为。我的任务是从InputStream读取并在超时后中断该读取。即使很多人说阻止读取也可以...

回答 1 投票 0

[启用Java安全管理器后,获取系统属性“ os.arch”时权限被拒绝期望

我有一个简单的Java应用程序ClientApp,它启用了Java安全管理器。该应用程序正在尝试调用获取“ os.arch”系统属性的Test jar方法。由于现在是时候...

回答 1 投票 0

CompletableFuture.runAsync与CompletableFuture数组

我在一个项目中找到此代码:int threadCount = 10; CompletableFuture> []期货=新的CompletableFuture> [threadCount]; for(int i = 0; i

回答 1 投票 0

futures.forEach(CompletableFuture :: join)并行运行所有任务?

我有多个可完成的期货创建为:CompletableFuture future1 = CompletableFuture.runAsync(()-> xxx); CompletableFuture future2 = CompletableFuture.runAsync(()...

回答 1 投票 0

Completable Future-使用Completable Future,我正在尝试从两个不同文件中获取数据

我试图从两个不同的文件中读取数据,一个是csv格式,另一个文件是xml数据。使用completeFuture,我试图从两个异步文件中读取数据。我正在获取...

回答 2 投票 0

如何知道春季启动@async并使用@scheduled完成所有线程

我需要使用异步调用REST API(一次调用50个)。每个呼叫都需要一些时间(20秒)来响应,然后进行一些处理。然后需要知道所有线程何时完成,...

回答 1 投票 0

CompletableFuture join()方法中的巨大延迟

所以我正在开发一个必须同时进行20个以上HTTP调用的应用程序。他们每个人都需要2-3秒才能得到回应。一次打一次这些电话相当慢(在...处40秒)[

回答 2 投票 1


从CompletableFuture.allOf()执行中收集抛出的异常

具有以下暂存代码:公共静态void main(String [] args)抛出ExecutionException,InterruptedException {CompletableFuture process1 = CompletableFuture.runAsync(()-&...

回答 1 投票 1

(Datastax 4.1.0)(Cassandra)如何使用session.executeAsync收集所有响应?

我想用execute来对cassandra db进行异步调用。在manuel中进行异步调用,我找到了这段代码,但我不明白如何将所有行收集到任何列表中。真正的基本呼叫,例如Select * from ...

回答 1 投票 0

Kotlin中的并发未来语法

我为Future使用简单的Java代码:Future futureTask = executor.submit(()-> {System.out.println(“ I'm Callable task。”); return 1 +1;});当我将其粘贴到kotlin类时...

回答 1 投票 1

带有CompletableFuture的Java多线程工作速度较慢

我试图编写代码以计算计算机上某些类型的文件。我同时测试了一个线程解决方案和多线程异步解决方案,看来一个线程的运行速度更快。是...

回答 3 投票 0

Completable Future异常处理runAsync&thenRun

假设我有此示例代码,并且在runAsync中遇到异常。我的问题是,此异常是否会阻止thenRun运行,因为thenRun在与...

回答 1 投票 0

如何将已检查的异常从CompletableFuture传递到ControllerAdvice

如何使controllerAdvice类捕获从completablefutrue引发的异常。在下面的代码中,我有一个方法checkId抛出一个已检查的异常。我称这个方法为...

回答 1 投票 1

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